SubscribableStream class

サブスクライブ可能Stream クラスの新しいインスタンスを初期化します。

new SubscribableStream(options?: DuplexOptions)

パラメーター

length: number

プロパティ値

static defaultMaxListeners: number

プロパティ値

継承元 EventEmitter.defaultMaxListeners

readable: boolean

プロパティ値

継承元 Readable.readable

readableFlowing: boolean | null

プロパティ値

継承元 Readable.readableFlowing

readableHighWaterMark: number

プロパティ値

継承元 Readable.readableHighWaterMark

readableLength: number

プロパティ値

継承元 Readable.readableLength

writable: boolean

プロパティ値

継承元 Duplex.writable

writableHighWaterMark: number

プロパティ値

継承元 Duplex.writableHighWaterMark

writableLength: number

プロパティ値

継承元 Duplex.writableLength

データを受信したときにストリームをサブスクライブします。

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

パラメーター

イベント エミッタ: 次のようなドキュメントに対して定義されたイベント。

1. 閉じる
2. [データ]
3. end
4. 読み やすい
5. error

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

パラメーター

戻り値

継承元 Readable.addListener

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

パラメーター

戻り値

継承元 Readable.addListener

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

パラメーター

戻り値

継承元 Readable.addListener

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

パラメーター

戻り値

継承元 Readable.addListener

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

パラメーター

戻り値

継承元 Readable.addListener

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

パラメーター

戻り値

継承元 Readable.addListener

function cork()

継承元 Duplex.cor

function destroy(error?: Error)

パラメーター

継承元 Readable.destroy

function emit(event: "close"): boolean

パラメーター

戻り値

継承元 Readable.emit

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

パラメーター

戻り値

継承元 Readable.emit

function emit(event: "end"): boolean

パラメーター

戻り値

継承元 Readable.emit

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

パラメーター

戻り値

継承元 Readable.emit

function emit(event: "readable"): boolean

パラメーター

戻り値

継承元 Readable.emit

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

パラメーター

戻り値

継承元 Readable.emit

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

パラメーター

継承元 Duplex.end

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

パラメーター

継承元 Duplex.end

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

パラメーター

継承元 Duplex.end

function eventNames(): Array<string | symbol>

戻り値

継承元 EventEmitter.eventNames

function getMaxListeners(): number

戻り値

継承元 EventEmitter.getMaxListeners

function isPaused(): boolean

戻り値

継承元 Readable.isPaused

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

パラメーター

戻り値

継承元 EventEmitter.listenerCount

function listenerCount(type: string | symbol): number

パラメーター

戻り値

継承元 EventEmitter.listenerCount

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

パラメーター

戻り値

継承元 EventEmitter.listeners

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

パラメーター

戻り値

継承元 EventEmitter.off

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

パラメーター

戻り値

継承元 Readable.on

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

パラメーター

戻り値

継承元 Readable.on

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

パラメーター

戻り値

継承元 Readable.on

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

パラメーター

戻り値

継承元 Readable.on

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

パラメーター

戻り値

継承元 Readable.on

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

パラメーター

戻り値

継承元 Readable.on

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

パラメーター

戻り値

継承元 Readable.once

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

パラメーター

戻り値

継承元 Readable.once

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

パラメーター

戻り値

継承元 Readable.once

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

パラメーター

戻り値

継承元 Readable.once

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

パラメーター

戻り値

継承元 Readable.once

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

パラメーター

戻り値

継承元 EventEmitter.once

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

パラメーター

戻り値

継承元 Readable.once

function pause(): this

戻り値

継承元 Readable.pause

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

パラメーター

戻り値

internal.pipe から継承

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

パラメーター

戻り値

継承元 Readable.prependListener

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

パラメーター

戻り値

継承元 Readable.prependListener

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

パラメーター

戻り値

継承元 Readable.prependListener

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

パラメーター

戻り値

継承元 Readable.prependListener

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

パラメーター

戻り値

継承元 Readable.prependListener

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

パラメーター

戻り値

継承元 Readable.prependListener

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

パラメーター

戻り値

継承元 Readable.prependOnceListener

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

パラメーター

戻り値

継承元 Readable.prependOnceListener

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

パラメーター

戻り値

継承元 Readable.prependOnceListener

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

パラメーター

戻り値

継承元 Readable.prependOnceListener

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

パラメーター

戻り値

継承元 Readable.prependOnceListener

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

パラメーター

戻り値

継承元 Readable.prependOnceListener

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

パラメーター

戻り値

継承元 Readable.push

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

パラメーター

戻り値

継承元 EventEmitter.rawListeners

function read(size?: number): any

パラメーター

戻り値

継承元 Readable.read

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

パラメーター

戻り値

継承元 EventEmitter.removeAllListeners

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

パラメーター

戻り値

継承元 Readable.removeListener

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

パラメーター

戻り値

継承元 Readable.removeListener

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

パラメーター

戻り値

継承元 Readable.removeListener

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

パラメーター

戻り値

継承元 Readable.removeListener

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

パラメーター

戻り値

継承元 Readable.removeListener

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

パラメーター

戻り値

継承元 Readable.removeListener

function resume(): this

戻り値

継承元 Readable.resume

function setDefaultEncoding(encoding: string): this

パラメーター

戻り値

継承元 Duplex.setDefaultEncoding

function setEncoding(encoding: string): this

パラメーター

戻り値

継承元 Readable.setEncoding

function setMaxListeners(n: number): this

パラメーター

戻り値

継承元 EventEmitter.setMaxListeners

function uncork()

継承元 Duplex.uncork

function unpipe(destination?: WritableStream): this

パラメーター

戻り値

継承元 Readable.unpipe

function unshift(chunk: any)

パラメーター

継承元 Readable.unshift

function wrap(oldStream: ReadableStream): this

パラメーター

戻り値

継承元 Readable.wrap

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

パラメーター

戻り値

継承元 Duplex.write

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

パラメーター

戻り値

継承元 Duplex.write