Condividi tramite

StreamManager class

  • Riferimento
Pacchetto:
botframework-streaming

Orchestra e gestisce i flussi.

Costruttori

StreamManager((contentStreamAssembler: PayloadAssembler) => void)

Inizializza una nuova istanza della classe StreamManager .

Metodi

closeStream(string)

Chiude il PayloadAssembler assegnato al SottoscrivibileStream con l'ID specificato.
getPayloadAssembler(string)

Recupera un PayloadAssembler con l'ID specificato, se presente, in caso contrario viene creata una nuova istanza e assegnato l'ID specificato.
getPayloadStream(IHeader)

Recupera l' SubscribableStream dal PayloadAssembler gestito da questa gestione.
onReceive(IHeader, SubscribableStream, number)

Consente di impostare il comportamento dell'PayloadAssembler gestito quando vengono ricevuti i dati.

Dettagli costruttore

StreamManager((contentStreamAssembler: PayloadAssembler) => void)

Inizializza una nuova istanza della classe StreamManager .

new StreamManager(onCancelStream: (contentStreamAssembler: PayloadAssembler) => void)

Parametri

onCancelStream

(contentStreamAssembler: PayloadAssembler) => void

Funzione da attivare se il flusso gestito viene annullato.

Dettagli metodo

closeStream(string)

Chiude il PayloadAssembler assegnato al SottoscrivibileStream con l'ID specificato.

function closeStream(id: string)

Parametri

id

string

ID del Di sottoscrizione Di sottoscrizione.

getPayloadAssembler(string)

Recupera un PayloadAssembler con l'ID specificato, se presente, in caso contrario viene creata una nuova istanza e assegnato l'ID specificato.

function getPayloadAssembler(id: string): PayloadAssembler

Parametri

id

string

ID del PayloadAssembler da recuperare o creare.

Restituisce

PayloadAssembler

PayloadAssembler con l'ID specificato.

getPayloadStream(IHeader)

Recupera l' SubscribableStream dal PayloadAssembler gestito da questa gestione.

function getPayloadStream(header: IHeader): SubscribableStream

Parametri

header
IHeader

Intestazione del Di sottoscrizione .

Restituisce

SubscribableStream

Di sottoscrizione con l'intestazione specificata.

onReceive(IHeader, SubscribableStream, number)

Consente di impostare il comportamento dell'PayloadAssembler gestito quando vengono ricevuti i dati.

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

Parametri

header
IHeader

Intestazione del flusso.

contentStream
SubscribableStream

Di sottoscrizione a cui scrivere i dati in ingresso.

contentLength

number

Quantità di dati da scrivere in contentStream.