次の方法で共有


PayloadAssemblerManager class

ペイロードのアセンブリを調整します。

コンストラクター

PayloadAssemblerManager(StreamManager, (id: string, receiveResponse: IReceiveResponse) => Promise<void>, (id: string, receiveRequest: IReceiveRequest) => Promise<void>)

PayloadAssemblerManager クラスの新しいインスタンスを初期化します。

メソッド

getPayloadStream(IHeader)

アセンブラーのペイロードをストリームとして取得します。

onReceive(IHeader, SubscribableStream, number)

受信ストリームで新しいバイトを受信したときにアセンブラーが実行するアクション。

コンストラクターの詳細

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

ストリームの長さ (有限の場合)。