StreamManager class
ストリームを調整および管理します。
コンストラクター
Stream |
StreamManager クラスの新しいインスタンスを初期化します。 |
メソッド
close |
指定した ID で SubscribableStream に割り当てられている PayloadAssembler を閉じます。 |
get |
特定の ID が存在する場合は、PayloadAssembler を取得します。存在しない場合は、新しいインスタンスが作成され、指定された ID が割り当てられます。 |
get |
このマネージャーが管理する PayloadAssembler から SubscribableStream 取得します。 |
on |
データの受信時にマネージド PayloadAssembler の動作を設定するために使用されます。 |
コンストラクターの詳細
StreamManager((contentStreamAssembler: PayloadAssembler) => void)
StreamManager クラスの新しいインスタンスを初期化します。
new StreamManager(onCancelStream: (contentStreamAssembler: PayloadAssembler) => void)
パラメーター
- onCancelStream
-
(contentStreamAssembler: PayloadAssembler) => void
マネージド ストリームが取り消された場合にトリガーする関数。
メソッドの詳細
closeStream(string)
指定した ID で SubscribableStream に割り当てられている PayloadAssembler を閉じます。
function closeStream(id: string)
パラメーター
- id
-
string
閉じる サブスクライブ可能なStream の ID。
getPayloadAssembler(string)
特定の ID が存在する場合は、PayloadAssembler を取得します。存在しない場合は、新しいインスタンスが作成され、指定された ID が割り当てられます。
function getPayloadAssembler(id: string): PayloadAssembler
パラメーター
- id
-
string
取得または作成する PayloadAssembler の ID。
戻り値
getPayloadStream(IHeader)
このマネージャーが管理する PayloadAssembler から SubscribableStream 取得します。
function getPayloadStream(header: IHeader): SubscribableStream
パラメーター
- header
- IHeader
取得する SubscribableStream のヘッダー。
戻り値
指定されたヘッダーを持つ SubscribableStream。
onReceive(IHeader, SubscribableStream, number)
データの受信時にマネージド PayloadAssembler の動作を設定するために使用されます。
function onReceive(header: IHeader, contentStream: SubscribableStream, contentLength: number)
パラメーター
- header
- IHeader
ストリームのヘッダー。
- contentStream
- SubscribableStream
受信データを書き込む のサブスクライブ可能なStream。
- contentLength
-
number
contentStream に書き込むデータの量。