PayloadAssembler class

为流式处理库组装有效负载。

构造函数

PayloadAssembler(StreamManager, IAssemblerParams)

初始化 PayloadAssembler 类的新实例。

方法

close()

关闭汇编程序。

getPayloadStream()

检索汇编程序的有效负载作为流。

onReceive(IHeader, SubscribableStream, number)

在传入流上收到新字节时,汇编程序执行的操作。

构造函数详细信息

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

payloadType: string | PayloadTypes

属性值

string | PayloadTypes

方法详细信息

close()

关闭汇编程序。

function close()

getPayloadStream()

检索汇编程序的有效负载作为流。

function getPayloadStream(): SubscribableStream

返回

汇编程序有效负载的 SubscribableStream

onReceive(IHeader, SubscribableStream, number)

在传入流上收到新字节时,汇编程序执行的操作。

function onReceive(header: IHeader, stream: SubscribableStream, _contentLength: number)

参数

header
IHeader

流的标头。

stream
SubscribableStream

正在组装的传入流。

_contentLength

number

流的长度(如果有限)。