ProtocolAdapter class
Crée un adaptateur de protocole pour la diffusion en continu.
Constructeurs
| Protocol |
Crée une instance de la classe d’adaptateur de protocole. |
Méthodes
| on |
Exécute le pipeline de réception en cas d’annulation. |
| on |
Exécute le pipeline de réception lors de l’entrée d’une requête. |
| on |
Exécute le pipeline de réception lorsqu’une réponse est entrée. |
| send |
Envoie une requête sur le gestionnaire de demandes attaché. |
Détails du constructeur
ProtocolAdapter(RequestHandler, RequestManager, PayloadSender, PayloadReceiver)
Crée une instance de la classe d’adaptateur de protocole.
new ProtocolAdapter(requestHandler: RequestHandler, requestManager: RequestManager, sender: PayloadSender, receiver: PayloadReceiver)Paramètres
- requestHandler
- RequestHandler
RequestHandler qui traite les requêtes entrantes.
- requestManager
- RequestManager
Le RequestManager qui traite les demandes sortantes.
- sender
- PayloadSender
Le PayloadSender à utiliser avec les requêtes sortantes.
- receiver
- PayloadReceiver
Le PayloadReceiver à utiliser avec les requêtes entrantes.
Détails de la méthode
onCancelStream(PayloadAssembler)
Exécute le pipeline de réception en cas d’annulation.
function onCancelStream(contentStreamAssembler: PayloadAssembler)Paramètres
- contentStreamAssembler
- PayloadAssembler
L’assembleur de charge utile traite les données entrantes que cette demande d’annulation cible.
onReceiveRequest(string, IReceiveRequest)
Exécute le pipeline de réception lors de l’entrée d’une requête.
function onReceiveRequest(id: string, request: IReceiveRequest): Promise<void>Paramètres
- id
-
string
L’ID des ressources créées pour la réponse est affecté.
- request
- IReceiveRequest
Requête entrante à traiter.
Retours
Promise<void>
onReceiveResponse(string, IReceiveResponse)
Exécute le pipeline de réception lorsqu’une réponse est entrée.
function onReceiveResponse(id: string, response: IReceiveResponse): Promise<void>Paramètres
- id
-
string
L’ID des ressources créées pour la réponse est affecté.
- response
- IReceiveResponse
Réponse entrante au processus.
Retours
Promise<void>
sendRequest(StreamingRequest)
Envoie une requête sur le gestionnaire de demandes attaché.
function sendRequest(request: StreamingRequest): Promise<IReceiveResponse>Paramètres
- request
- StreamingRequest
Demande sortante à envoyer.
Retours
Promise<IReceiveResponse>
Réponse à la requête spécifiée.