PayloadAssembler class
为流式处理库组装有效负载。
构造函数
Payload |
初始化 PayloadAssembler 类的新实例。 |
属性
content |
|
end | |
id | |
payload |
方法
close() | 关闭汇编程序。 |
get |
检索汇编程序的有效负载作为流。 |
on |
在传入流上收到新字节时,汇编程序执行的操作。 |
构造函数详细信息
PayloadAssembler(StreamManager, IAssemblerParams)
初始化 PayloadAssembler 类的新实例。
new PayloadAssembler(streamManager: StreamManager, params: IAssemblerParams)
参数
- streamManager
- StreamManager
StreamManager 管理正在组装的流。
- params
- IAssemblerParams
流式处理汇编程序的参数。
属性详细信息
contentLength
contentLength: number
属性值
number
end
end: boolean
属性值
boolean
id
id: string
属性值
string
payloadType
方法详细信息
close()
关闭汇编程序。
function close()
getPayloadStream()
onReceive(IHeader, SubscribableStream, number)
在传入流上收到新字节时,汇编程序执行的操作。
function onReceive(header: IHeader, stream: SubscribableStream, _contentLength: number)
参数
- header
- IHeader
流的标头。
- stream
- SubscribableStream
正在组装的传入流。
- _contentLength
-
number
流的长度(如果有限)。