PayloadAssemblerManager class
Koordiniert die Assembly von Nutzlasten.
Konstruktoren
Methoden
get |
Ruft die Nutzlast des Assemblers als Datenstrom ab. |
on |
Die Aktion, die der Assembler ausführt, wenn neue Bytes im eingehenden Datenstrom empfangen werden. |
Details zum Konstruktor
PayloadAssemblerManager(StreamManager, (id: string, receiveResponse: IReceiveResponse) => Promise<void>, (id: string, receiveRequest: IReceiveRequest) => Promise<void>)
Initialisiert eine neue Instanz der PayloadAssemblerManager Klasse.
new PayloadAssemblerManager(streamManager: StreamManager, onReceiveResponse: (id: string, receiveResponse: IReceiveResponse) => Promise<void>, onReceiveRequest: (id: string, receiveRequest: IReceiveRequest) => Promise<void>)
Parameter
- streamManager
- StreamManager
Der StreamManager die Verwaltung des zusammengefügten Datenstroms.
- onReceiveResponse
-
(id: string, receiveResponse: IReceiveResponse) => Promise<void>
Funktion, die ausgeführt wird, wenn neue Bytes in einem response
Datenstrom empfangen werden.
- onReceiveRequest
-
(id: string, receiveRequest: IReceiveRequest) => Promise<void>
Funktion, die ausgeführt wird, wenn neue Bytes in einem request
Datenstrom empfangen werden.
Details zur Methode
getPayloadStream(IHeader)
Ruft die Nutzlast des Assemblers als Datenstrom ab.
function getPayloadStream(header: IHeader): SubscribableStream
Parameter
- header
- IHeader
Die Kopfzeile des abzurufenden Datenstroms.
Gibt zurück
Eine AbonnierenableStream- der Nutzlast des Assemblers.
onReceive(IHeader, SubscribableStream, number)
Die Aktion, die der Assembler ausführt, wenn neue Bytes im eingehenden Datenstrom empfangen werden.
function onReceive(header: IHeader, contentStream: SubscribableStream, contentLength: number)
Parameter
- header
- IHeader
Die Kopfzeile des Datenstroms.
- contentStream
- SubscribableStream
Der eingehende Datenstrom, der zusammengestellt wird.
- contentLength
-
number
Die Länge des Datenstroms, falls endlich.