Поделиться через

StreamManager class

  • Ссылка
Пакет:
botframework-streaming

Оркеструет потоки и управляет ими.

Конструкторы

StreamManager((contentStreamAssembler: PayloadAssembler) => void)

Инициализирует новый экземпляр класса StreamManager.

Методы

closeStream(string)

Закрывает payloadAssembler , назначенный subscribableStream с указанным идентификатором.
getPayloadAssembler(string)

Извлекает payloadAssembler с заданным идентификатором, в противном случае создается новый экземпляр и назначается заданный идентификатор.
getPayloadStream(IHeader)

Извлекает subscribableStream из PayloadAssembler, управляет этот менеджер.
onReceive(IHeader, SubscribableStream, number)

Используется для задания поведения управляемого PayloadAssembler при получении данных.

Сведения о конструкторе

StreamManager((contentStreamAssembler: PayloadAssembler) => void)

Инициализирует новый экземпляр класса StreamManager.

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

Параметры

onCancelStream

(contentStreamAssembler: PayloadAssembler) => void

Функция для активации, если управляемый поток отменен.

Сведения о методе

closeStream(string)

Закрывает payloadAssembler , назначенный subscribableStream с указанным идентификатором.

function closeStream(id: string)

Параметры

id

string

Идентификатор подписки .

getPayloadAssembler(string)

Извлекает payloadAssembler с заданным идентификатором, в противном случае создается новый экземпляр и назначается заданный идентификатор.

function getPayloadAssembler(id: string): PayloadAssembler

Параметры

id

string

Идентификатор PayloadAssembler для извлечения или создания.

Возвращаемое значение

PayloadAssembler

PayloadAssembler с указанным идентификатором.

getPayloadStream(IHeader)

Извлекает subscribableStream из PayloadAssembler, управляет этот менеджер.

function getPayloadStream(header: IHeader): SubscribableStream

Параметры

header
IHeader

Заголовок объекта SubscribableStream для получения.

Возвращаемое значение

SubscribableStream

SubscribableStream с заданным заголовком.

onReceive(IHeader, SubscribableStream, number)

Используется для задания поведения управляемого PayloadAssembler при получении данных.

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

Параметры

header
IHeader

Заголовок потока.

contentStream
SubscribableStream

SubscribableStream для записи входящих данных.

contentLength

number

Объем данных для записи в contentStream.