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

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

Заголовок потока, который требуется извлечь.

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

SubscribableStream

Подписка полезных данных сборщика.

onReceive(IHeader, SubscribableStream, number)

Действие сборщика выполняется при получении новых байтов в входящего потока.

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

Параметры

header
IHeader

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

contentStream
SubscribableStream

Входящие потоки собираются.

contentLength

number

Длина потока, если ограниченная.