PayloadReceiver class
ストリーミング用のペイロード レシーバー。
プロパティ
| disconnected | |
| is |
現在の接続状態を取得する |
メソッド
| connect(ITransport |
トランスポート レシーバーに接続します。 |
| disconnect(Transport |
このレシーバーを強制的に切断します。 |
| subscribe((header: IHeader) => Subscribable |
新しいデータが入ったときに通知を受け取るために、この受信者をサブスクライブできるようにします。 |
プロパティの詳細
disconnected
isConnected
現在の接続状態を取得する
boolean isConnectedプロパティ値
boolean
トランスポート送信者に接続されている場合は true。
メソッドの詳細
connect(ITransportReceiver)
トランスポート レシーバーに接続します。
function connect(receiver: ITransportReceiver): Promise<void>パラメーター
- receiver
- ITransportReceiver
ITransportReceiver オブジェクトから受信データをプルします。
戻り値
Promise<void>
受信側が完了したときに解決される Promise
disconnect(TransportDisconnectedEvent)
このレシーバーを強制的に切断します。
function disconnect(event?: TransportDisconnectedEvent)パラメーター
切断イベントのブロードキャスト時に含めるイベント引数。
subscribe((header: IHeader) => SubscribableStream, (header: IHeader, stream: SubscribableStream, count: number) => void)
新しいデータが入ったときに通知を受け取るために、この受信者をサブスクライブできるようにします。
function subscribe(getStream: (header: IHeader) => SubscribableStream, receiveAction: (header: IHeader, stream: SubscribableStream, count: number) => void)パラメーター
- getStream
-
(header: IHeader) => SubscribableStream
新しいストリームを受信したときのコールバック。
- receiveAction
-
(header: IHeader, stream: SubscribableStream, count: number) => void
新しいメッセージを受信したときのコールバック。