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


ProtocolAdapter class

Создает адаптер протокола для потоковой передачи.

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

ProtocolAdapter(RequestHandler, RequestManager, PayloadSender, PayloadReceiver)

Создает новый экземпляр класса адаптера протокола.

Методы

onCancelStream(PayloadAssembler)

Выполняет конвейер получения при отмене.

onReceiveRequest(string, IReceiveRequest)

Выполняет конвейер получения при поступлении запроса.

onReceiveResponse(string, IReceiveResponse)

Выполняет конвейер получения при появлении ответа.

sendRequest(StreamingRequest)

Отправляет запрос через подключенный диспетчер запросов.

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

ProtocolAdapter(RequestHandler, RequestManager, PayloadSender, PayloadReceiver)

Создает новый экземпляр класса адаптера протокола.

new ProtocolAdapter(requestHandler: RequestHandler, requestManager: RequestManager, sender: PayloadSender, receiver: PayloadReceiver)

Параметры

requestHandler
RequestHandler

RequestHandler, которая будет обрабатывать входящие запросы.

requestManager
RequestManager

RequestManager, которая будет обрабатывать исходящие запросы.

sender
PayloadSender

полезных данных для использования с исходящими запросами.

receiver
PayloadReceiver

PayloadReceiver для использования с входящими запросами.

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

onCancelStream(PayloadAssembler)

Выполняет конвейер получения при отмене.

function onCancelStream(contentStreamAssembler: PayloadAssembler)

Параметры

contentStreamAssembler
PayloadAssembler

Сборщик полезных данных обрабатывает входящие данные, целевые для этого запроса отмены.

onReceiveRequest(string, IReceiveRequest)

Выполняет конвейер получения при поступлении запроса.

function onReceiveRequest(id: string, request: IReceiveRequest): Promise<void>

Параметры

id

string

Идентификатор ресурсов, созданных для ответа, будет назначен.

request
IReceiveRequest

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

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

Promise<void>

onReceiveResponse(string, IReceiveResponse)

Выполняет конвейер получения при появлении ответа.

function onReceiveResponse(id: string, response: IReceiveResponse): Promise<void>

Параметры

id

string

Идентификатор ресурсов, созданных для ответа, будет назначен.

response
IReceiveResponse

Входящий ответ на процесс.

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

Promise<void>

sendRequest(StreamingRequest)

Отправляет запрос через подключенный диспетчер запросов.

function sendRequest(request: StreamingRequest): Promise<IReceiveResponse>

Параметры

request
StreamingRequest

Исходящий запрос для отправки.

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

Promise<IReceiveResponse>

Ответ на указанный запрос.