ProtocolAdapter class
Crea un adattatore di protocollo per streaming.
Costruttori
| Protocol |
Crea una nuova istanza della classe dell'adattatore del protocollo. |
Metodi
| on |
Esegue la pipeline di ricezione quando si verifica un annullamento. |
| on |
Esegue la pipeline di ricezione quando arriva una richiesta. |
| on |
Esegue la pipeline di ricezione quando arriva una risposta. |
| send |
Invia una richiesta sul gestore richieste collegato. |
Dettagli costruttore
ProtocolAdapter(RequestHandler, RequestManager, PayloadSender, PayloadReceiver)
Crea una nuova istanza della classe dell'adattatore del protocollo.
new ProtocolAdapter(requestHandler: RequestHandler, requestManager: RequestManager, sender: PayloadSender, receiver: PayloadReceiver)Parametri
- requestHandler
- RequestHandler
RequestHandler che elabora le richieste in ingresso.
- requestManager
- RequestManager
RequestManager che elabora le richieste in uscita.
- sender
- PayloadSender
PayloadSender da usare con le richieste in uscita.
- receiver
- PayloadReceiver
PayloadReceiver da usare con le richieste in ingresso.
Dettagli metodo
onCancelStream(PayloadAssembler)
Esegue la pipeline di ricezione quando si verifica un annullamento.
function onCancelStream(contentStreamAssembler: PayloadAssembler)Parametri
- contentStreamAssembler
- PayloadAssembler
Assembler payload che elabora i dati in ingresso a cui è destinata la richiesta di annullamento.
onReceiveRequest(string, IReceiveRequest)
Esegue la pipeline di ricezione quando arriva una richiesta.
function onReceiveRequest(id: string, request: IReceiveRequest): Promise<void>Parametri
- id
-
string
ID a cui verranno assegnate le risorse create per la risposta.
- request
- IReceiveRequest
Richiesta in ingresso da elaborare.
Restituisce
Promise<void>
onReceiveResponse(string, IReceiveResponse)
Esegue la pipeline di ricezione quando arriva una risposta.
function onReceiveResponse(id: string, response: IReceiveResponse): Promise<void>Parametri
- id
-
string
ID a cui verranno assegnate le risorse create per la risposta.
- response
- IReceiveResponse
Risposta in ingresso da elaborare.
Restituisce
Promise<void>
sendRequest(StreamingRequest)
Invia una richiesta sul gestore richieste collegato.
function sendRequest(request: StreamingRequest): Promise<IReceiveResponse>Parametri
- request
- StreamingRequest
Richiesta in uscita da inviare.
Restituisce
Promise<IReceiveResponse>
Risposta alla richiesta specificata.