PayloadAssemblerManager class
Mengatur rakitan payload.
Konstruktor
Metode
| get |
Mengambil payload perakitan sebagai aliran. |
| on |
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.