StreamManager class

Paket:

botframework-streaming

Mengatur dan mengelola aliran.

Konstruktor

StreamManager((contentStreamAssembler: PayloadAssembler) => void)

Menginisialisasi instans baru kelas StreamManager.

Metode

closeStream(string)	Menutup PayloadAssembler yang ditetapkan ke SubscribableStream dengan ID yang diberikan.
getPayloadAssembler(string)	Mengambil PayloadAssembler dengan ID yang diberikan jika ada, jika tidak, instans baru dibuat dan diberi ID yang diberikan.
getPayloadStream(IHeader)	Mengambil SubscribableStream dari PayloadAssembler dikelola manajer ini.
onReceive(IHeader, SubscribableStream, number)	Digunakan untuk mengatur perilaku PayloadAssembler terkelola saat data diterima.

Detail Konstruktor

StreamManager((contentStreamAssembler: PayloadAssembler) => void)

Menginisialisasi instans baru kelas StreamManager.

new StreamManager(onCancelStream: (contentStreamAssembler: PayloadAssembler) => void)

Parameter

onCancelStream

(contentStreamAssembler: PayloadAssembler) => void

Fungsi untuk memicu jika aliran terkelola dibatalkan.

Detail Metode

closeStream(string)

Menutup PayloadAssembler yang ditetapkan ke SubscribableStream dengan ID yang diberikan.

function closeStream(id: string)

Parameter

id

string

ID SubscribableStream untuk ditutup.

getPayloadAssembler(string)

Mengambil PayloadAssembler dengan ID yang diberikan jika ada, jika tidak, instans baru dibuat dan diberi ID yang diberikan.

function getPayloadAssembler(id: string): PayloadAssembler

Parameter

id

string

ID PayloadAssembler untuk diambil atau dibuat.

Mengembalikan

PayloadAssembler

PayloadAssembler dengan ID yang diberikan.

getPayloadStream(IHeader)

Mengambil SubscribableStream dari PayloadAssembler dikelola manajer ini.

function getPayloadStream(header: IHeader): SubscribableStream

Parameter

header

IHeader

Header SubscribableStream untuk diambil.

Mengembalikan

SubscribableStream

SubscribableStream dengan header yang diberikan.

onReceive(IHeader, SubscribableStream, number)

Digunakan untuk mengatur perilaku PayloadAssembler terkelola saat data diterima.

function onReceive(header: IHeader, contentStream: SubscribableStream, contentLength: number)

Parameter

header

IHeader

Header aliran.

contentStream

SubscribableStream

SubscribableStream untuk menulis data masuk.

contentLength

number

Jumlah data yang akan ditulis ke contentStream.