Bagikan melalui


PayloadAssemblerManager class

Mengatur rakitan payload.

Konstruktor

PayloadAssemblerManager(StreamManager, (id: string, receiveResponse: IReceiveResponse) => Promise<void>, (id: string, receiveRequest: IReceiveRequest) => Promise<void>)

Menginisialisasi instans baru kelas PayloadAssemblerManager.

Metode

getPayloadStream(IHeader)

Mengambil payload perakitan sebagai aliran.

onReceive(IHeader, SubscribableStream, number)

Tindakan yang dijalankan perakitan ketika byte baru diterima pada aliran masuk.

Detail Konstruktor

PayloadAssemblerManager(StreamManager, (id: string, receiveResponse: IReceiveResponse) => Promise<void>, (id: string, receiveRequest: IReceiveRequest) => Promise<void>)

Menginisialisasi instans baru kelas PayloadAssemblerManager.

new PayloadAssemblerManager(streamManager: StreamManager, onReceiveResponse: (id: string, receiveResponse: IReceiveResponse) => Promise<void>, onReceiveRequest: (id: string, receiveRequest: IReceiveRequest) => Promise<void>)

Parameter

streamManager
StreamManager

StreamManager mengelola aliran yang sedang dirakit.

onReceiveResponse

(id: string, receiveResponse: IReceiveResponse) => Promise<void>

Fungsi yang dijalankan saat byte baru diterima pada aliran response.

onReceiveRequest

(id: string, receiveRequest: IReceiveRequest) => Promise<void>

Fungsi yang dijalankan saat byte baru diterima pada aliran request.

Detail Metode

getPayloadStream(IHeader)

Mengambil payload perakitan sebagai aliran.

function getPayloadStream(header: IHeader): SubscribableStream

Parameter

header
IHeader

Header Aliran yang akan diambil.

Mengembalikan

SubscribableStream payload perakitan.

onReceive(IHeader, SubscribableStream, number)

Tindakan yang dijalankan perakitan ketika byte baru diterima pada aliran masuk.

function onReceive(header: IHeader, contentStream: SubscribableStream, contentLength: number)

Parameter

header
IHeader

Header aliran.

contentStream
SubscribableStream

Aliran masuk sedang dirakit.

contentLength

number

Panjang aliran, jika terbatas.