Freigeben über


PayloadReceiver class

Nutzlastempfänger für Streaming.

Eigenschaften

disconnected
isConnected

Abrufen des aktuellen verbundenen Zustands

Methoden

connect(ITransportReceiver)

Herstellen einer Verbindung mit einem Transportempfänger

disconnect(TransportDisconnectedEvent)

Erzwingen Sie, dass dieser Empfänger die Verbindung trennt.

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.

Details zur Eigenschaft

disconnected

disconnected?: TransportDisconnectedEventHandler

Eigenschaftswert

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

event
TransportDisconnectedEvent

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.