PayloadAssemblerManager class
ペイロードのアセンブリを調整します。
コンストラクター
メソッド
| get |
アセンブラーのペイロードをストリームとして取得します。 |
| on |
受信ストリームで新しいバイトを受信したときにアセンブラーが実行するアクション。 |
コンストラクターの詳細
PayloadAssemblerManager(StreamManager, (id: string, receiveResponse: IReceiveResponse) => Promise<void>, (id: string, receiveRequest: IReceiveRequest) => Promise<void>)
PayloadAssemblerManager クラスの新しいインスタンスを初期化します。
new PayloadAssemblerManager(streamManager: StreamManager, onReceiveResponse: (id: string, receiveResponse: IReceiveResponse) => Promise<void>, onReceiveRequest: (id: string, receiveRequest: IReceiveRequest) => Promise<void>)パラメーター
- streamManager
- StreamManager
StreamManager、アセンブリされるストリームを管理します。
- onReceiveResponse
-
(id: string, receiveResponse: IReceiveResponse) => Promise<void>
response ストリームで新しいバイトを受信したときに実行される関数。
- onReceiveRequest
-
(id: string, receiveRequest: IReceiveRequest) => Promise<void>
request ストリームで新しいバイトを受信したときに実行される関数。
メソッドの詳細
getPayloadStream(IHeader)
アセンブラーのペイロードをストリームとして取得します。
function getPayloadStream(header: IHeader): SubscribableStreamパラメーター
- header
- IHeader
取得するストリームのヘッダー。
戻り値
アセンブラーのペイロードの SubscribableStream。
onReceive(IHeader, SubscribableStream, number)
受信ストリームで新しいバイトを受信したときにアセンブラーが実行するアクション。
function onReceive(header: IHeader, contentStream: SubscribableStream, contentLength: number)パラメーター
- header
- IHeader
ストリームのヘッダー。
- contentStream
- SubscribableStream
アセンブリされている受信ストリーム。
- contentLength
-
number
ストリームの長さ (有限の場合)。