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

流的长度(如果有限)。