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
新しいメッセージを受信したときのコールバック。