Condividi tramite


PayloadReceiver class

Ricevitore del payload per lo streaming.

Proprietà

disconnected
isConnected

Ottenere lo stato corrente della connessione

Metodi

connect(ITransportReceiver)

Si connette a un ricevitore di trasporto

disconnect(TransportDisconnectedEvent)

Forzare la disconnessione del ricevitore.

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

Consente la sottoscrizione a questo ricevitore per ricevere una notifica quando arrivano nuovi dati.

Dettagli proprietà

disconnected

disconnected?: TransportDisconnectedEventHandler

Valore della proprietà

isConnected

Ottenere lo stato corrente della connessione

boolean isConnected

Valore della proprietà

boolean

true se è connesso a un mittente del trasporto.

Dettagli metodo

connect(ITransportReceiver)

Si connette a un ricevitore di trasporto

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

Parametri

receiver
ITransportReceiver

Oggetto ITransportReceiver da cui eseguire il pull dei dati in ingresso.

Restituisce

Promise<void>

una promessa che si risolve al termine del ricevitore

disconnect(TransportDisconnectedEvent)

Forzare la disconnessione del ricevitore.

function disconnect(event?: TransportDisconnectedEvent)

Parametri

event
TransportDisconnectedEvent

Argomenti dell'evento da includere durante la trasmissione dell'evento di disconnessione.

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

Consente la sottoscrizione a questo ricevitore per ricevere una notifica quando arrivano nuovi dati.

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

Parametri

getStream

(header: IHeader) => SubscribableStream

Callback quando è stato ricevuto un nuovo flusso.

receiveAction

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

Callback quando viene ricevuto un nuovo messaggio.