ProtocolAdapter class
Erstellt einen Protokolladapter für Streaming.
Konstruktoren
| Protocol |
Erstellt eine neue Instanz der Protokolladapterklasse. |
Methoden
| on |
Führt die Empfangspipeline aus, wenn ein Abbruch eintritt. |
| on |
Führt die Empfangspipeline aus, wenn eine Anforderung eingeht. |
| on |
Führt die Empfangspipeline aus, wenn eine Antwort eingeht. |
| send |
Sendet eine Anforderung über den angefügten Anforderungs-Manager. |
Details zum Konstruktor
ProtocolAdapter(RequestHandler, RequestManager, PayloadSender, PayloadReceiver)
Erstellt eine neue Instanz der Protokolladapterklasse.
new ProtocolAdapter(requestHandler: RequestHandler, requestManager: RequestManager, sender: PayloadSender, receiver: PayloadReceiver)Parameter
- requestHandler
- RequestHandler
Der RequestHandler, der eingehende Anforderungen verarbeitet.
- requestManager
- RequestManager
Die RequestManager-, die ausgehende Anforderungen verarbeitet.
- sender
- PayloadSender
Der PayloadSender für die Verwendung mit ausgehenden Anforderungen.
- receiver
- PayloadReceiver
Die PayloadReceiver- für die Verwendung mit eingehenden Anforderungen.
Details zur Methode
onCancelStream(PayloadAssembler)
Führt die Empfangspipeline aus, wenn ein Abbruch eintritt.
function onCancelStream(contentStreamAssembler: PayloadAssembler)Parameter
- contentStreamAssembler
- PayloadAssembler
Der Nutzlastassembler verarbeitet die eingehenden Daten, auf die diese Abbruchanforderung abzielt.
onReceiveRequest(string, IReceiveRequest)
Führt die Empfangspipeline aus, wenn eine Anforderung eingeht.
function onReceiveRequest(id: string, request: IReceiveRequest): Promise<void>Parameter
- id
-
string
Die ID, die für die Antwort erstellt wurde, wird zugewiesen.
- request
- IReceiveRequest
Die eingehende Anforderung, die verarbeitet werden soll.
Gibt zurück
Promise<void>
onReceiveResponse(string, IReceiveResponse)
Führt die Empfangspipeline aus, wenn eine Antwort eingeht.
function onReceiveResponse(id: string, response: IReceiveResponse): Promise<void>Parameter
- id
-
string
Die ID, die für die Antwort erstellt wurde, wird zugewiesen.
- response
- IReceiveResponse
Die eingehende Antwort auf den Prozess.
Gibt zurück
Promise<void>
sendRequest(StreamingRequest)
Sendet eine Anforderung über den angefügten Anforderungs-Manager.
function sendRequest(request: StreamingRequest): Promise<IReceiveResponse>Parameter
- request
- StreamingRequest
Die ausgehende Anforderung, die gesendet werden soll.
Gibt zurück
Promise<IReceiveResponse>
Die Antwort auf die angegebene Anforderung.