Freigeben über

StreamManager class

  • Referenz
Paket:
botframework-streaming

Koordiniert und verwaltet Datenströme.

Konstruktoren

StreamManager((contentStreamAssembler: PayloadAssembler) => void)

Initialisiert eine neue Instanz der StreamManager Klasse.

Methoden

closeStream(string)

Schließt die PayloadAssembler-, die dem Abonnierenstream- mit der angegebenen ID zugewiesen ist.
getPayloadAssembler(string)

Ruft eine PayloadAssembler- mit der angegebenen ID ab, falls vorhanden, andernfalls wird eine neue Instanz erstellt und der angegebenen ID zugewiesen.
getPayloadStream(IHeader)

Ruft die abonnierendenStream- aus dem PayloadAssembler- diesem Manager ab.
onReceive(IHeader, SubscribableStream, number)

Wird verwendet, um das Verhalten des verwalteten PayloadAssembler- festzulegen, wenn Daten empfangen werden.

Details zum Konstruktor

StreamManager((contentStreamAssembler: PayloadAssembler) => void)

Initialisiert eine neue Instanz der StreamManager Klasse.

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

Parameter

onCancelStream

(contentStreamAssembler: PayloadAssembler) => void

Funktion, die ausgelöst wird, wenn der verwaltete Datenstrom abgebrochen wird.

Details zur Methode

closeStream(string)

Schließt die PayloadAssembler-, die dem Abonnierenstream- mit der angegebenen ID zugewiesen ist.

function closeStream(id: string)

Parameter

id

string

Die ID der AbonnierendenStream-, die geschlossen werden soll.

getPayloadAssembler(string)

Ruft eine PayloadAssembler- mit der angegebenen ID ab, falls vorhanden, andernfalls wird eine neue Instanz erstellt und der angegebenen ID zugewiesen.

function getPayloadAssembler(id: string): PayloadAssembler

Parameter

id

string

Die ID der PayloadAssembler-, die abgerufen oder erstellt werden soll.

Gibt zurück

PayloadAssembler

Die PayloadAssembler mit der angegebenen ID.

getPayloadStream(IHeader)

Ruft die abonnierendenStream- aus dem PayloadAssembler- diesem Manager ab.

function getPayloadStream(header: IHeader): SubscribableStream

Parameter

header
IHeader

Die Kopfzeile des abzurufenden abonnierendenStream-.

Gibt zurück

SubscribableStream

Die AbonnierenableStream- mit der angegebenen Kopfzeile.

onReceive(IHeader, SubscribableStream, number)

Wird verwendet, um das Verhalten des verwalteten PayloadAssembler- festzulegen, wenn Daten empfangen werden.

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

Parameter

header
IHeader

Die Kopfzeile des Datenstroms.

contentStream
SubscribableStream

Der AbonnierendenStream-, in den eingehende Daten geschrieben werden sollen.

contentLength

number

Die Datenmenge, die in den contentStream geschrieben werden soll.