PayloadAssemblerManager class
Orchestre l’assembly de charges utiles.
Constructeurs
| Payload |
Initialise une nouvelle instance de la classe PayloadAssemblerManager. |
Méthodes
| get |
Récupère la charge utile de l’assembleur en tant que flux. |
| on |
L’action exécutée par l’assembleur lorsque de nouveaux octets sont reçus sur le flux entrant. |
Détails du constructeur
PayloadAssemblerManager(StreamManager, (id: string, receiveResponse: IReceiveResponse) => Promise<void>, (id: string, receiveRequest: IReceiveRequest) => Promise<void>)
Initialise une nouvelle instance de la classe PayloadAssemblerManager.
new PayloadAssemblerManager(streamManager: StreamManager, onReceiveResponse: (id: string, receiveResponse: IReceiveResponse) => Promise<void>, onReceiveRequest: (id: string, receiveRequest: IReceiveRequest) => Promise<void>)Paramètres
- streamManager
- StreamManager
La StreamManager la gestion du flux en cours d’assemblage.
- onReceiveResponse
-
(id: string, receiveResponse: IReceiveResponse) => Promise<void>
Fonction qui s’exécute lorsque de nouveaux octets sont reçus sur un flux de response.
- onReceiveRequest
-
(id: string, receiveRequest: IReceiveRequest) => Promise<void>
Fonction qui s’exécute lorsque de nouveaux octets sont reçus sur un flux de request.
Détails de la méthode
getPayloadStream(IHeader)
Récupère la charge utile de l’assembleur en tant que flux.
function getPayloadStream(header: IHeader): SubscribableStreamParamètres
- header
- IHeader
En-tête du flux à récupérer.
Retours
Un AbonnementStream de la charge utile de l’assembleur.
onReceive(IHeader, SubscribableStream, number)
L’action exécutée par l’assembleur lorsque de nouveaux octets sont reçus sur le flux entrant.
function onReceive(header: IHeader, contentStream: SubscribableStream, contentLength: number)Paramètres
- header
- IHeader
En-tête du flux.
- contentStream
- SubscribableStream
Flux entrant en cours d’assemblage.
- contentLength
-
number
Longueur du flux, s’il est fini.