ProtocolAdapter class
Crea un adaptador de protocolo para Streaming.
Constructores
Protocol |
Crea una nueva instancia de la clase de adaptador de protocolo. |
Métodos
on |
Ejecuta la canalización de recepción cuando entra una cancelación. |
on |
Ejecuta la canalización de recepción cuando entra una solicitud. |
on |
Ejecuta la canalización de recepción cuando entra una respuesta. |
send |
Envía una solicitud sobre el administrador de solicitudes adjunto. |
Detalles del constructor
ProtocolAdapter(RequestHandler, RequestManager, PayloadSender, PayloadReceiver)
Crea una nueva instancia de la clase de adaptador de protocolo.
new ProtocolAdapter(requestHandler: RequestHandler, requestManager: RequestManager, sender: PayloadSender, receiver: PayloadReceiver)
Parámetros
- requestHandler
- RequestHandler
El RequestHandler que procesará las solicitudes entrantes.
- requestManager
- RequestManager
El RequestManager que procesará las solicitudes salientes.
- sender
- PayloadSender
El payloadSender de
- receiver
- PayloadReceiver
payloadReceiver para su uso con solicitudes entrantes.
Detalles del método
onCancelStream(PayloadAssembler)
Ejecuta la canalización de recepción cuando entra una cancelación.
function onCancelStream(contentStreamAssembler: PayloadAssembler)
Parámetros
- contentStreamAssembler
- PayloadAssembler
El ensamblador de carga procesa los datos entrantes a los que se dirige esta solicitud de cancelación.
onReceiveRequest(string, IReceiveRequest)
Ejecuta la canalización de recepción cuando entra una solicitud.
function onReceiveRequest(id: string, request: IReceiveRequest): Promise<void>
Parámetros
- id
-
string
Se asignará el identificador de los recursos creados para la respuesta.
- request
- IReceiveRequest
Solicitud entrante que se va a procesar.
Devoluciones
Promise<void>
onReceiveResponse(string, IReceiveResponse)
Ejecuta la canalización de recepción cuando entra una respuesta.
function onReceiveResponse(id: string, response: IReceiveResponse): Promise<void>
Parámetros
- id
-
string
Se asignará el identificador de los recursos creados para la respuesta.
- response
- IReceiveResponse
Respuesta entrante al proceso.
Devoluciones
Promise<void>
sendRequest(StreamingRequest)
Envía una solicitud sobre el administrador de solicitudes adjunto.
function sendRequest(request: StreamingRequest): Promise<IReceiveResponse>
Parámetros
- request
- StreamingRequest
Solicitud saliente que se va a enviar.
Devoluciones
Promise<IReceiveResponse>
Respuesta a la solicitud especificada.