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 eingeteilt werden. |
Details zur Eigenschaft
disconnected
isConnected
Abrufen des aktuellen verbundenen Zustands
boolean isConnected
Eigenschaftswert
boolean
true, wenn eine Verbindung mit einem Transportsender hergestellt wird.
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 der Verbindung 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 eingeteilt werden.
function subscribe(getStream: (header: IHeader) => SubscribableStream, receiveAction: (header: IHeader, stream: SubscribableStream, count: number) => void)
Parameter
- getStream
-
(header: IHeader) => SubscribableStream
Rückruf, wenn ein neuer Datenstrom empfangen wurde.
- receiveAction
-
(header: IHeader, stream: SubscribableStream, count: number) => void
Rückruf, wenn eine neue Nachricht empfangen wurde.