PayloadReceiver class
Ricevitore del payload per lo streaming.
Proprietà
| disconnected | |
| is |
Ottenere lo stato corrente della connessione |
Metodi
| connect(ITransport |
Si connette a un ricevitore di trasporto |
| disconnect(Transport |
Forzare la disconnessione del ricevitore. |
| subscribe((header: IHeader) => Subscribable |
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
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.