ProtocolAdapter class
Создает адаптер протокола для потоковой передачи.
Конструкторы
| Protocol |
Создает новый экземпляр класса адаптера протокола. |
Методы
| on |
Выполняет конвейер получения при отмене. |
| on |
Выполняет конвейер получения при поступлении запроса. |
| on |
Выполняет конвейер получения при появлении ответа. |
| send |
Отправляет запрос через подключенный диспетчер запросов. |
Сведения о конструкторе
ProtocolAdapter(RequestHandler, RequestManager, PayloadSender, PayloadReceiver)
Создает новый экземпляр класса адаптера протокола.
new ProtocolAdapter(requestHandler: RequestHandler, requestManager: RequestManager, sender: PayloadSender, receiver: PayloadReceiver)
Параметры
- requestHandler
- RequestHandler
RequestHandler, которая будет обрабатывать входящие запросы.
- requestManager
- RequestManager
- sender
- PayloadSender
полезных данных
- receiver
- 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>
Ответ на указанный запрос.