PayloadAssemblerManager class
Orquestra o assembly de cargas.
Construtores
Métodos
| get |
Recupera o conteúdo do assembler como um fluxo. |
| on |
A ação que o assembler executa quando novos bytes são recebidos no fluxo de entrada. |
Detalhes do construtor
PayloadAssemblerManager(StreamManager, (id: string, receiveResponse: IReceiveResponse) => Promise<void>, (id: string, receiveRequest: IReceiveRequest) => Promise<void>)
Inicializa uma nova instância da classe PayloadAssemblerManager.
new PayloadAssemblerManager(streamManager: StreamManager, onReceiveResponse: (id: string, receiveResponse: IReceiveResponse) => Promise<void>, onReceiveRequest: (id: string, receiveRequest: IReceiveRequest) => Promise<void>)Parâmetros
- streamManager
- StreamManager
O StreamManager gerenciando o fluxo que está sendo montado.
- onReceiveResponse
-
(id: string, receiveResponse: IReceiveResponse) => Promise<void>
Função que é executada quando novos bytes são recebidos em um fluxo de response.
- onReceiveRequest
-
(id: string, receiveRequest: IReceiveRequest) => Promise<void>
Função que é executada quando novos bytes são recebidos em um fluxo de request.
Detalhes do método
getPayloadStream(IHeader)
Recupera o conteúdo do assembler como um fluxo.
function getPayloadStream(header: IHeader): SubscribableStreamParâmetros
- header
- IHeader
O cabeçalho do fluxo a ser recuperado.
Retornos
Um SubscribableStream do conteúdo do assembler.
onReceive(IHeader, SubscribableStream, number)
A ação que o assembler executa quando novos bytes são recebidos no fluxo de entrada.
function onReceive(header: IHeader, contentStream: SubscribableStream, contentLength: number)Parâmetros
- header
- IHeader
O cabeçalho do fluxo.
- contentStream
- SubscribableStream
O fluxo de entrada que está sendo montado.
- contentLength
-
number
O comprimento do fluxo, se finito.