PayloadReceiver class
Nutzlastempfänger für Streaming.
Eigenschaften
disconnected | |
is |
Abrufen des aktuellen verbundenen Zustands |
Methoden
connect(ITransport |
Herstellen einer Verbindung mit einem Transportempfänger |
disconnect(Transport |
Erzwingen Sie, dass dieser Empfänger die Verbindung trennt. |
subscribe((header: IHeader) => Subscribable |
Ermöglicht das Abonnieren dieses Empfängers, um benachrichtigt zu werden, wenn neue Daten einsteigen. |
Details zur Eigenschaft
disconnected
isConnected
Abrufen des aktuellen verbundenen Zustands
boolean isConnected
Eigenschaftswert
boolean
true, wenn eine Verbindung mit einem Transportsender besteht.
Details zur Methode
connect(ITransportReceiver)
Herstellen einer Verbindung mit einem Transportempfänger
function connect(receiver: ITransportReceiver): Promise<void>
Parameter
- receiver
- ITransportReceiver
Das ITransportReceiver-Objekt , aus dem eingehende Daten abgerufen werden sollen.
Gibt zurück
Promise<void>
eine Zusage, die aufgelöst wird, wenn der Empfänger abgeschlossen ist
disconnect(TransportDisconnectedEvent)
Erzwingen Sie, dass dieser Empfänger die Verbindung trennt.
function disconnect(event?: TransportDisconnectedEvent)
Parameter
Ereignisargumente, die beim Senden eines Trennungsereignisses eingeschlossen werden sollen.
subscribe((header: IHeader) => SubscribableStream, (header: IHeader, stream: SubscribableStream, count: number) => void)
Ermöglicht das Abonnieren dieses Empfängers, um benachrichtigt zu werden, wenn neue Daten einsteigen.
function subscribe(getStream: (header: IHeader) => SubscribableStream, receiveAction: (header: IHeader, stream: SubscribableStream, count: number) => void)
Parameter
- getStream
-
(header: IHeader) => SubscribableStream
Rückruf, wenn ein neuer Stream empfangen wurde.
- receiveAction
-
(header: IHeader, stream: SubscribableStream, count: number) => void
Rückruf, wenn eine neue Nachricht empfangen wurde.