PayloadAssemblerManager class
Organiza el ensamblado de cargas.
Constructores
Métodos
get |
Recupera la carga del ensamblador como una secuencia. |
on |
La acción que ejecuta el ensamblador cuando se reciben nuevos bytes en la secuencia entrante. |
Detalles del constructor
PayloadAssemblerManager(StreamManager, (id: string, receiveResponse: IReceiveResponse) => Promise<void>, (id: string, receiveRequest: IReceiveRequest) => Promise<void>)
Inicializa una nueva instancia de la clase PayloadAssemblerManager.
new PayloadAssemblerManager(streamManager: StreamManager, onReceiveResponse: (id: string, receiveResponse: IReceiveResponse) => Promise<void>, onReceiveRequest: (id: string, receiveRequest: IReceiveRequest) => Promise<void>)
Parámetros
- streamManager
- StreamManager
El StreamManager administrar la secuencia que se va a ensamblar.
- onReceiveResponse
-
(id: string, receiveResponse: IReceiveResponse) => Promise<void>
Función que se ejecuta cuando se reciben nuevos bytes en una secuencia de response
.
- onReceiveRequest
-
(id: string, receiveRequest: IReceiveRequest) => Promise<void>
Función que se ejecuta cuando se reciben nuevos bytes en una secuencia de request
.
Detalles del método
getPayloadStream(IHeader)
Recupera la carga del ensamblador como una secuencia.
function getPayloadStream(header: IHeader): SubscribableStream
Parámetros
- header
- IHeader
Encabezado de la secuencia que se va a recuperar.
Devoluciones
suscripciónStream de la carga del ensamblador.
onReceive(IHeader, SubscribableStream, number)
La acción que ejecuta el ensamblador cuando se reciben nuevos bytes en la secuencia entrante.
function onReceive(header: IHeader, contentStream: SubscribableStream, contentLength: number)
Parámetros
- header
- IHeader
Encabezado de la secuencia.
- contentStream
- SubscribableStream
Secuencia entrante que se va a ensamblar.
- contentLength
-
number
Longitud de la secuencia, si es finita.