ProtocolAdapter class
Cria um adaptador de protocolo para Streaming.
Construtores
| Protocol |
Cria uma nova instância da classe do adaptador de protocolo. |
Métodos
| on |
Executa o pipeline de recebimento quando um cancelamento é recebido. |
| on |
Executa o pipeline de recebimento quando uma solicitação entra. |
| on |
Executa o pipeline de recebimento quando uma resposta é recebida. |
| send |
Envia uma solicitação pelo gerenciador de solicitações anexado. |
Detalhes do construtor
ProtocolAdapter(RequestHandler, RequestManager, PayloadSender, PayloadReceiver)
Cria uma nova instância da classe do adaptador de protocolo.
new ProtocolAdapter(requestHandler: RequestHandler, requestManager: RequestManager, sender: PayloadSender, receiver: PayloadReceiver)Parâmetros
- requestHandler
- RequestHandler
O RequestHandler que processará solicitações de entrada.
- requestManager
- RequestManager
O RequestManager
- sender
- PayloadSender
O PayloadSender para uso com solicitações de saída.
- receiver
- PayloadReceiver
O PayloadReceiver para uso com solicitações de entrada.
Detalhes do método
onCancelStream(PayloadAssembler)
Executa o pipeline de recebimento quando um cancelamento é recebido.
function onCancelStream(contentStreamAssembler: PayloadAssembler)Parâmetros
- contentStreamAssembler
- PayloadAssembler
O assembler de carga que processa os dados de entrada direcionados a essa solicitação de cancelamento.
onReceiveRequest(string, IReceiveRequest)
Executa o pipeline de recebimento quando uma solicitação entra.
function onReceiveRequest(id: string, request: IReceiveRequest): Promise<void>Parâmetros
- id
-
string
A ID dos recursos criados para a resposta será atribuída.
- request
- IReceiveRequest
A solicitação de entrada a ser processada.
Retornos
Promise<void>
onReceiveResponse(string, IReceiveResponse)
Executa o pipeline de recebimento quando uma resposta é recebida.
function onReceiveResponse(id: string, response: IReceiveResponse): Promise<void>Parâmetros
- id
-
string
A ID dos recursos criados para a resposta será atribuída.
- response
- IReceiveResponse
A resposta de entrada a ser processada.
Retornos
Promise<void>
sendRequest(StreamingRequest)
Envia uma solicitação pelo gerenciador de solicitações anexado.
function sendRequest(request: StreamingRequest): Promise<IReceiveResponse>Parâmetros
- request
- StreamingRequest
A solicitação de saída a ser enviada.
Retornos
Promise<IReceiveResponse>
A resposta à solicitação especificada.