Bagikan melalui


PayloadReceiver class

Penerima payload untuk streaming.

Properti

disconnected
isConnected

Mendapatkan status tersambung saat ini

Metode

connect(ITransportReceiver)

Menyambungkan ke penerima transportasi

disconnect(TransportDisconnectedEvent)

Paksa penerima ini untuk memutuskan sambungan.

subscribe((header: IHeader) => SubscribableStream, (header: IHeader, stream: SubscribableStream, count: number) => void)

Memungkinkan berlangganan penerima ini untuk diberi tahu ketika data baru masuk.

Detail Properti

disconnected

disconnected?: TransportDisconnectedEventHandler

Nilai Properti

isConnected

Mendapatkan status tersambung saat ini

boolean isConnected

Nilai Properti

boolean

true jika tersambung ke pengirim transportasi.

Detail Metode

connect(ITransportReceiver)

Menyambungkan ke penerima transportasi

function connect(receiver: ITransportReceiver): Promise<void>

Parameter

receiver
ITransportReceiver

Objek ITransportReceiver untuk menarik data masuk.

Mengembalikan

Promise<void>

janji yang diselesaikan ketika penerima selesai

disconnect(TransportDisconnectedEvent)

Paksa penerima ini untuk memutuskan sambungan.

function disconnect(event?: TransportDisconnectedEvent)

Parameter

event
TransportDisconnectedEvent

Argumen peristiwa untuk disertakan saat menyiarkan peristiwa pemutusan sambungan.

subscribe((header: IHeader) => SubscribableStream, (header: IHeader, stream: SubscribableStream, count: number) => void)

Memungkinkan berlangganan penerima ini untuk diberi tahu ketika data baru masuk.

function subscribe(getStream: (header: IHeader) => SubscribableStream, receiveAction: (header: IHeader, stream: SubscribableStream, count: number) => void)

Parameter

getStream

(header: IHeader) => SubscribableStream

Panggilan balik saat aliran baru telah diterima.

receiveAction

(header: IHeader, stream: SubscribableStream, count: number) => void

Panggilan balik saat pesan baru telah diterima.