Freigeben über


PayloadAssemblerManager class

Koordiniert die Assembly von Nutzlasten.

Konstruktoren

PayloadAssemblerManager(StreamManager, (id: string, receiveResponse: IReceiveResponse) => Promise<void>, (id: string, receiveRequest: IReceiveRequest) => Promise<void>)

Initialisiert eine neue Instanz der PayloadAssemblerManager Klasse.

Methoden

getPayloadStream(IHeader)

Ruft die Nutzlast des Assemblers als Datenstrom ab.

onReceive(IHeader, SubscribableStream, number)

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.