PayloadAssemblerManager class
协调有效负载的程序集。
构造函数
方法
| get |
检索汇编程序的有效负载作为流。 |
| on |
在传入流上收到新字节时，汇编程序执行的操作。 |
构造函数详细信息
PayloadAssemblerManager(StreamManager, (id: string, receiveResponse: IReceiveResponse) => Promise<void>, (id: string, receiveRequest: IReceiveRequest) => Promise<void>)
初始化 PayloadAssemblerManager 类的新实例。
new PayloadAssemblerManager(streamManager: StreamManager, onReceiveResponse: (id: string, receiveResponse: IReceiveResponse) => Promise<void>, onReceiveRequest: (id: string, receiveRequest: IReceiveRequest) => Promise<void>)参数
- streamManager
- StreamManager
StreamManager 管理正在组装的流。
- onReceiveResponse
-
(id: string, receiveResponse: IReceiveResponse) => Promise<void>
在 response 流上收到新字节时执行的函数。
- onReceiveRequest
-
(id: string, receiveRequest: IReceiveRequest) => Promise<void>
在 request 流上收到新字节时执行的函数。
方法详细信息
getPayloadStream(IHeader)
检索汇编程序的有效负载作为流。
function getPayloadStream(header: IHeader): SubscribableStream参数
- header
- IHeader
要检索的流的标头。
返回
汇编程序有效负载的 SubscribableStream。
onReceive(IHeader, SubscribableStream, number)
在传入流上收到新字节时，汇编程序执行的操作。
function onReceive(header: IHeader, contentStream: SubscribableStream, contentLength: number)参数
- header
- IHeader
流的标头。
- contentStream
- SubscribableStream
正在组装的传入流。
- contentLength
-
number
流的长度（如果有限）。