次の方法で共有


StreamManager class

ストリームを調整および管理します。

コンストラクター

StreamManager((contentStreamAssembler: PayloadAssembler) => void)

StreamManager クラスの新しいインスタンスを初期化します。

メソッド

closeStream(string)

指定した ID で SubscribableStream に割り当てられている PayloadAssembler を閉じます。

getPayloadAssembler(string)

特定の ID が存在する場合は、PayloadAssembler を取得します。存在しない場合は、新しいインスタンスが作成され、指定された ID が割り当てられます。

getPayloadStream(IHeader)

このマネージャーが管理する PayloadAssembler から SubscribableStream 取得します。

onReceive(IHeader, SubscribableStream, number)

データの受信時にマネージド 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。

戻り値

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 に書き込むデータの量。