SubscribableStream class

Paket:

botframework-streaming

Ekstensi Duplex yang beroperasi bersama dengan PayloadAssembler untuk mengonversi byte mentah menjadi bentuk yang dapat dikonsumsi.

Memperluas

Duplex

Konstruktor

SubscribableStream(DuplexOptions)

Menginisialisasi instans baru kelas SubscribableStream.

Properti

length

Properti yang Diwariskan

defaultMaxListeners
readable
readableFlowing
readableHighWaterMark
readableLength
writable
writableHighWaterMark
writableLength

Metode

subscribe((chunk: any) => void)

Berlangganan ke aliran saat menerima data.

Metode yang Diwarisi

addListener("close", () => void)	Pemancar peristiwa Peristiwa yang ditentukan pada dokumen termasuk: tutup data ujung Mudah dibaca kesalahan
addListener("data", (chunk: any) => void)
addListener("end", () => void)
addListener("error", (err: Error) => void)
addListener("readable", () => void)
addListener(string | symbol, (args: any[]) => void)
cork()
destroy(Error)
emit("close")
emit("data", any)
emit("end")
emit("error", Error)
emit("readable")
emit(string | symbol, any[])
end(() => void)
end(any, () => void)
end(any, string, () => void)
eventNames()
getMaxListeners()
isPaused()
listenerCount(EventEmitter, string | symbol)
listenerCount(string | symbol)
listeners(string | symbol)
off(string | symbol, (args: any[]) => void)
on("close", () => void)
on("data", (chunk: any) => void)
on("end", () => void)
on("error", (err: Error) => void)
on("readable", () => void)
on(string | symbol, (args: any[]) => void)
once("close", () => void)
once("data", (chunk: any) => void)
once("end", () => void)
once("error", (err: Error) => void)
once("readable", () => void)
once(NodeEventTarget, string | symbol)
once(string | symbol, (args: any[]) => void)
pause()
pipe<T>(T, { end?: boolean })
prependListener("close", () => void)
prependListener("data", (chunk: any) => void)
prependListener("end", () => void)
prependListener("error", (err: Error) => void)
prependListener("readable", () => void)
prependListener(string | symbol, (args: any[]) => void)
prependOnceListener("close", () => void)
prependOnceListener("data", (chunk: any) => void)
prependOnceListener("end", () => void)
prependOnceListener("error", (err: Error) => void)
prependOnceListener("readable", () => void)
prependOnceListener(string | symbol, (args: any[]) => void)
push(any, string)
rawListeners(string | symbol)
read(number)
removeAllListeners(string | symbol)
removeListener("close", () => void)
removeListener("data", (chunk: any) => void)
removeListener("end", () => void)
removeListener("error", (err: Error) => void)
removeListener("readable", () => void)
removeListener(string | symbol, (args: any[]) => void)
resume()
setDefaultEncoding(string)
setEncoding(string)
setMaxListeners(number)
uncork()
unpipe(WritableStream)
unshift(any)
wrap(ReadableStream)
write(any, (error: Error | null | undefined) => void)
write(any, string, (error: Error | null | undefined) => void)

Detail Konstruktor

SubscribableStream(DuplexOptions)

Menginisialisasi instans baru kelas SubscribableStream.

new SubscribableStream(options?: DuplexOptions)

Parameter

options

DuplexOptions

DuplexOptions yang digunakan saat membuat aliran ini.

Detail Properti

length

length: number

Nilai Properti

number

Detail Properti yang Diwariskan

defaultMaxListeners

static defaultMaxListeners: number

Nilai Properti

number

Diwarisi Dari EventEmitter.defaultMaxListeners

readable

readable: boolean

Nilai Properti

boolean

Diwariskan Dari Readable.readable

readableFlowing

readableFlowing: boolean | null

Nilai Properti

boolean | null

Diwariskan Dari Readable.readableFlowing

readableHighWaterMark

readableHighWaterMark: number

Nilai Properti

number

Diwariskan Dari Readable.readableHighWaterMark

readableLength

readableLength: number

Nilai Properti

number

Diwariskan Dari Readable.readableLength

writable

writable: boolean

Nilai Properti

boolean

Diwariskan Dari Duplex.writable

writableHighWaterMark

writableHighWaterMark: number

Nilai Properti

number

Diwariskan Dari Duplex.writableHighWaterMark

writableLength

writableLength: number

Nilai Properti

number

Diwariskan Dari Duplex.writableLength

Detail Metode

subscribe((chunk: any) => void)

Berlangganan ke aliran saat menerima data.

function subscribe(onData: (chunk: any) => void)

Parameter

onData

(chunk: any) => void

Panggilan balik yang akan dipanggil ketika onData dijalankan.

Detail Metode yang Diwarisi

addListener("close", () => void)

Pemancar peristiwa Peristiwa yang ditentukan pada dokumen termasuk:

1. tutup
2. data
3. ujung
4. Mudah dibaca
5. kesalahan

function addListener(event: "close", listener: () => void): this

Parameter

event

"close"

listener

() => void

Mengembalikan

this

Diwariskan Dari Readable.addListener

addListener("data", (chunk: any) => void)

function addListener(event: "data", listener: (chunk: any) => void): this

Parameter

event

"data"

listener

(chunk: any) => void

Mengembalikan

this

Diwariskan Dari Readable.addListener

addListener("end", () => void)

function addListener(event: "end", listener: () => void): this

Parameter

event

"end"

listener

() => void

Mengembalikan

this

Diwariskan Dari Readable.addListener

addListener("error", (err: Error) => void)

function addListener(event: "error", listener: (err: Error) => void): this

Parameter

event

"error"

listener

(err: Error) => void

Mengembalikan

this

Diwariskan Dari Readable.addListener

addListener("readable", () => void)

function addListener(event: "readable", listener: () => void): this

Parameter

event

"readable"

listener

() => void

Mengembalikan

this

Diwariskan Dari Readable.addListener

addListener(string | symbol, (args: any[]) => void)

function addListener(event: string | symbol, listener: (args: any[]) => void): this

Parameter

event

string | symbol

listener

(args: any[]) => void

Mengembalikan

this

Diwariskan Dari Readable.addListener

cork()

function cork()

Diwariskan Dari Duplex.cork

destroy(Error)

function destroy(error?: Error)

Parameter

error

Error

Diwariskan Dari Readable.destroy

emit("close")

function emit(event: "close"): boolean

Parameter

event

"close"

Mengembalikan

boolean

Diwariskan Dari Readable.emit

emit("data", any)

function emit(event: "data", chunk: any): boolean

Parameter

event

"data"

chunk

any

Mengembalikan

boolean

Diwariskan Dari Readable.emit

emit("end")

function emit(event: "end"): boolean

Parameter

event

"end"

Mengembalikan

boolean

Diwariskan Dari Readable.emit

emit("error", Error)

function emit(event: "error", err: Error): boolean

Parameter

event

"error"

err

Error

Mengembalikan

boolean

Diwariskan Dari Readable.emit

emit("readable")

function emit(event: "readable"): boolean

Parameter

event

"readable"

Mengembalikan

boolean

Diwariskan Dari Readable.emit

emit(string | symbol, any[])

function emit(event: string | symbol, args: any[]): boolean

Parameter

event

string | symbol

args

any[]

Mengembalikan

boolean

Diwariskan Dari Readable.emit

end(() => void)

function end(cb?: () => void)

Parameter

cb

() => void

Diwarisi Dari Duplex.end

end(any, () => void)

function end(chunk: any, cb?: () => void)

Parameter

chunk

any

cb

() => void

Diwarisi Dari Duplex.end

end(any, string, () => void)

function end(chunk: any, encoding?: string, cb?: () => void)

Parameter

chunk

any

encoding

string

cb

() => void

Diwarisi Dari Duplex.end

eventNames()

function eventNames(): Array<string | symbol>

Mengembalikan

Array<string | symbol>

Diwariskan Dari EventEmitter.eventNames

getMaxListeners()

function getMaxListeners(): number

Mengembalikan

number

Diwariskan Dari EventEmitter.getMaxListeners

isPaused()

function isPaused(): boolean

Mengembalikan

boolean

Diwariskan Dari Readable.isPaused

listenerCount(EventEmitter, string | symbol)

Peringatan

API ini sudah tidak digunakan lagi.

since v4.0.0

static function listenerCount(emitter: EventEmitter, event: string | symbol): number

Parameter

emitter

EventEmitter

event

string | symbol

Mengembalikan

number

Diwarisi Dari EventEmitter.listenerCount

listenerCount(string | symbol)

function listenerCount(type: string | symbol): number

Parameter

type

string | symbol

Mengembalikan

number

Diwarisi Dari EventEmitter.listenerCount

listeners(string | symbol)

function listeners(event: string | symbol): Function[]

Parameter

event

string | symbol

Mengembalikan

Function[]

Diwariskan Dari EventEmitter.listeners

off(string | symbol, (args: any[]) => void)

function off(event: string | symbol, listener: (args: any[]) => void): this

Parameter

event

string | symbol

listener

(args: any[]) => void

Mengembalikan

this

Diwariskan Dari EventEmitter.off

on("close", () => void)

function on(event: "close", listener: () => void): this

Parameter

event

"close"

listener

() => void

Mengembalikan

this

Diwariskan Dari Dapat Dibaca.on

on("data", (chunk: any) => void)

function on(event: "data", listener: (chunk: any) => void): this

Parameter

event

"data"

listener

(chunk: any) => void

Mengembalikan

this

Diwariskan Dari Dapat Dibaca.on

on("end", () => void)

function on(event: "end", listener: () => void): this

Parameter

event

"end"

listener

() => void

Mengembalikan

this

Diwariskan Dari Dapat Dibaca.on

on("error", (err: Error) => void)

function on(event: "error", listener: (err: Error) => void): this

Parameter

event

"error"

listener

(err: Error) => void

Mengembalikan

this

Diwariskan Dari Dapat Dibaca.on

on("readable", () => void)

function on(event: "readable", listener: () => void): this

Parameter

event

"readable"

listener

() => void

Mengembalikan

this

Diwariskan Dari Dapat Dibaca.on

on(string | symbol, (args: any[]) => void)

function on(event: string | symbol, listener: (args: any[]) => void): this

Parameter

event

string | symbol

listener

(args: any[]) => void

Mengembalikan

this

Diwariskan Dari Dapat Dibaca.on

once("close", () => void)

function once(event: "close", listener: () => void): this

Parameter

event

"close"

listener

() => void

Mengembalikan

this

Diwariskan Dari Dapat Dibaca.sekali

once("data", (chunk: any) => void)

function once(event: "data", listener: (chunk: any) => void): this

Parameter

event

"data"

listener

(chunk: any) => void

Mengembalikan

this

Diwariskan Dari Dapat Dibaca.sekali

once("end", () => void)

function once(event: "end", listener: () => void): this

Parameter

event

"end"

listener

() => void

Mengembalikan

this

Diwariskan Dari Dapat Dibaca.sekali

once("error", (err: Error) => void)

function once(event: "error", listener: (err: Error) => void): this

Parameter

event

"error"

listener

(err: Error) => void

Mengembalikan

this

Diwariskan Dari Dapat Dibaca.sekali

once("readable", () => void)

function once(event: "readable", listener: () => void): this

Parameter

event

"readable"

listener

() => void

Mengembalikan

this

Diwariskan Dari Dapat Dibaca.sekali

once(NodeEventTarget, string | symbol)

static function once(emitter: NodeEventTarget, event: string | symbol): Promise<any[]>

Parameter

emitter

NodeEventTarget

event

string | symbol

Mengembalikan

Promise<any[]>

Diwarisi Dari EventEmitter.once

once(string | symbol, (args: any[]) => void)

function once(event: string | symbol, listener: (args: any[]) => void): this

Parameter

event

string | symbol

listener

(args: any[]) => void

Mengembalikan

this

Diwariskan Dari Dapat Dibaca.sekali

pause()

function pause(): this

Mengembalikan

this

Diwariskan Dari Readable.pause

pipe<T>(T, { end?: boolean })

function pipe<T>(destination: T, options?: { end?: boolean }): T

Parameter

destination

T

options

{ end?: boolean }

Mengembalikan

T

Diwariskan Dari internal.pipe

prependListener("close", () => void)

function prependListener(event: "close", listener: () => void): this

Parameter

event

"close"

listener

() => void

Mengembalikan

this

Diwariskan Dari Readable.prependListener

prependListener("data", (chunk: any) => void)

function prependListener(event: "data", listener: (chunk: any) => void): this

Parameter

event

"data"

listener

(chunk: any) => void

Mengembalikan

this

Diwariskan Dari Readable.prependListener

prependListener("end", () => void)

function prependListener(event: "end", listener: () => void): this

Parameter

event

"end"

listener

() => void

Mengembalikan

this

Diwariskan Dari Readable.prependListener

prependListener("error", (err: Error) => void)

function prependListener(event: "error", listener: (err: Error) => void): this

Parameter

event

"error"

listener

(err: Error) => void

Mengembalikan

this

Diwariskan Dari Readable.prependListener

prependListener("readable", () => void)

function prependListener(event: "readable", listener: () => void): this

Parameter

event

"readable"

listener

() => void

Mengembalikan

this

Diwariskan Dari Readable.prependListener

prependListener(string | symbol, (args: any[]) => void)

function prependListener(event: string | symbol, listener: (args: any[]) => void): this

Parameter

event

string | symbol

listener

(args: any[]) => void

Mengembalikan

this

Diwariskan Dari Readable.prependListener

prependOnceListener("close", () => void)

function prependOnceListener(event: "close", listener: () => void): this

Parameter

event

"close"

listener

() => void

Mengembalikan

this

Diwariskan Dari Readable.prependOnceListener

prependOnceListener("data", (chunk: any) => void)

function prependOnceListener(event: "data", listener: (chunk: any) => void): this

Parameter

event

"data"

listener

(chunk: any) => void

Mengembalikan

this

Diwariskan Dari Readable.prependOnceListener

prependOnceListener("end", () => void)

function prependOnceListener(event: "end", listener: () => void): this

Parameter

event

"end"

listener

() => void

Mengembalikan

this

Diwariskan Dari Readable.prependOnceListener

prependOnceListener("error", (err: Error) => void)

function prependOnceListener(event: "error", listener: (err: Error) => void): this

Parameter

event

"error"

listener

(err: Error) => void

Mengembalikan

this

Diwariskan Dari Readable.prependOnceListener

prependOnceListener("readable", () => void)

function prependOnceListener(event: "readable", listener: () => void): this

Parameter

event

"readable"

listener

() => void

Mengembalikan

this

Diwariskan Dari Readable.prependOnceListener

prependOnceListener(string | symbol, (args: any[]) => void)

function prependOnceListener(event: string | symbol, listener: (args: any[]) => void): this

Parameter

event

string | symbol

listener

(args: any[]) => void

Mengembalikan

this

Diwariskan Dari Readable.prependOnceListener

push(any, string)

function push(chunk: any, encoding?: string): boolean

Parameter

chunk

any

encoding

string

Mengembalikan

boolean

Diwariskan Dari Readable.push

rawListeners(string | symbol)

function rawListeners(event: string | symbol): Function[]

Parameter

event

string | symbol

Mengembalikan

Function[]

Diwariskan Dari EventEmitter.rawListeners

read(number)

function read(size?: number): any

Parameter

size

number

Mengembalikan

any

Diwariskan Dari Readable.read

removeAllListeners(string | symbol)

function removeAllListeners(event?: string | symbol): this

Parameter

event

string | symbol

Mengembalikan

this

Diwariskan Dari EventEmitter.removeAllListeners

removeListener("close", () => void)

function removeListener(event: "close", listener: () => void): this

Parameter

event

"close"

listener

() => void

Mengembalikan

this

Diwariskan Dari Readable.removeListener

removeListener("data", (chunk: any) => void)

function removeListener(event: "data", listener: (chunk: any) => void): this

Parameter

event

"data"

listener

(chunk: any) => void

Mengembalikan

this

Diwariskan Dari Readable.removeListener

removeListener("end", () => void)

function removeListener(event: "end", listener: () => void): this

Parameter

event

"end"

listener

() => void

Mengembalikan

this

Diwariskan Dari Readable.removeListener

removeListener("error", (err: Error) => void)

function removeListener(event: "error", listener: (err: Error) => void): this

Parameter

event

"error"

listener

(err: Error) => void

Mengembalikan

this

Diwariskan Dari Readable.removeListener

removeListener("readable", () => void)

function removeListener(event: "readable", listener: () => void): this

Parameter

event

"readable"

listener

() => void

Mengembalikan

this

Diwariskan Dari Readable.removeListener

removeListener(string | symbol, (args: any[]) => void)

function removeListener(event: string | symbol, listener: (args: any[]) => void): this

Parameter

event

string | symbol

listener

(args: any[]) => void

Mengembalikan

this

Diwariskan Dari Readable.removeListener

resume()

function resume(): this

Mengembalikan

this

Diwariskan Dari Readable.resume

setDefaultEncoding(string)

function setDefaultEncoding(encoding: string): this

Parameter

encoding

string

Mengembalikan

this

Diwariskan Dari Duplex.setDefaultEncoding

setEncoding(string)

function setEncoding(encoding: string): this

Parameter

encoding

string

Mengembalikan

this

Diwariskan Dari Readable.setEncoding

setMaxListeners(number)

function setMaxListeners(n: number): this

Parameter

n

number

Mengembalikan

this

Diwarisi Dari EventEmitter.setMaxListeners

uncork()

function uncork()

Diwariskan Dari Duplex.uncork

unpipe(WritableStream)

function unpipe(destination?: WritableStream): this

Parameter

destination

WritableStream

Mengembalikan

this

Diwariskan Dari Readable.unpipe

unshift(any)

function unshift(chunk: any)

Parameter

chunk

any

Diwariskan Dari Readable.unshift

wrap(ReadableStream)

function wrap(oldStream: ReadableStream): this

Parameter

oldStream

ReadableStream

Mengembalikan

this

Diwariskan Dari Readable.wrap

write(any, (error: Error | null | undefined) => void)

function write(chunk: any, cb?: (error: Error | null | undefined) => void): boolean

Parameter

chunk

any

cb

(error: Error | null | undefined) => void

Mengembalikan

boolean

Diwariskan Dari Duplex.write

write(any, string, (error: Error | null | undefined) => void)

function write(chunk: any, encoding?: string, cb?: (error: Error | null | undefined) => void): boolean

Parameter

chunk

any

encoding

string

cb

(error: Error | null | undefined) => void

Mengembalikan

boolean

Diwariskan Dari Duplex.write