Compartir a través de


ProtocolAdapter class

Crea un adaptador de protocolo para Streaming.

Constructores

ProtocolAdapter(RequestHandler, RequestManager, PayloadSender, PayloadReceiver)

Crea una nueva instancia de la clase de adaptador de protocolo.

Métodos

onCancelStream(PayloadAssembler)

Ejecuta la canalización de recepción cuando entra una cancelación.

onReceiveRequest(string, IReceiveRequest)

Ejecuta la canalización de recepción cuando entra una solicitud.

onReceiveResponse(string, IReceiveResponse)

Ejecuta la canalización de recepción cuando entra una respuesta.

sendRequest(StreamingRequest)

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 para su uso con las solicitudes salientes.

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.