PayloadAssembler class

汇编流式处理库的有效负载。

构造函数

PayloadAssembler(StreamManager, IAssemblerParams)

初始化 PayloadAssembler 类的新实例。

属性

contentLength
end
id
payloadType

方法

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

流的长度(如果有限)。