PayloadAssemblerManager class

套件:

botframework-streaming

協調承載的元件。

建構函式

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

要擷取之 Stream 的標頭。

傳回

SubscribableStream

元件的承載 SubscribableStream。

onReceive(IHeader, SubscribableStream, number)

組合器在傳入數據流上收到新位元組時執行的動作。

function onReceive(header: IHeader, contentStream: SubscribableStream, contentLength: number)

參數

header

IHeader

數據流的標頭。

contentStream

SubscribableStream

正在組合的傳入數據流。

contentLength

number

如果為有限，則為數據流的長度。