Condividi tramite

PayloadAssemblerManager class

  • Riferimento
Pacchetto:
botframework-streaming

Orchestra l'assembly di payload.

Costruttori

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

Inizializza una nuova istanza della classe PayloadAssemblerManager.

Metodi

getPayloadStream(IHeader)

Recupera il payload dell'assembler come flusso.
onReceive(IHeader, SubscribableStream, number)

L'azione eseguita dall'assembler quando vengono ricevuti nuovi byte nel flusso in ingresso.

Dettagli costruttore

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

Inizializza una nuova istanza della classe PayloadAssemblerManager.

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

Parametri

streamManager
StreamManager

StreamManager la gestione del flusso in fase di assemblaggio.

onReceiveResponse

(id: string, receiveResponse: IReceiveResponse) => Promise<void>

Funzione eseguita quando vengono ricevuti nuovi byte in un flusso response.

onReceiveRequest

(id: string, receiveRequest: IReceiveRequest) => Promise<void>

Funzione eseguita quando vengono ricevuti nuovi byte in un flusso request.

Dettagli metodo

getPayloadStream(IHeader)

Recupera il payload dell'assembler come flusso.

function getPayloadStream(header: IHeader): SubscribableStream

Parametri

header
IHeader

Intestazione del flusso da recuperare.

Restituisce

SubscribableStream

Oggetto Di sottoscrizione del payload dell'assembler.

onReceive(IHeader, SubscribableStream, number)

L'azione eseguita dall'assembler quando vengono ricevuti nuovi byte nel flusso in ingresso.

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

Parametri

header
IHeader

Intestazione del flusso.

contentStream
SubscribableStream

Flusso in ingresso da assemblare.

contentLength

number

Lunghezza del flusso, se finita.