Options
All
  • Public
  • Public/Protected
  • All
Menu

Class Stream

Hierarchy

  • Stream

Index

Constructors

constructor

Properties

Private _data

_data: Array<Data> = new Array<Data>()

Protected _end

Private _maxThresholdSize

_maxThresholdSize: number = 16384

Private _objectMode

_objectMode: boolean = false

Private _onclose

_onclose: Array<notifyCallback> = new Array<notifyCallback>()

Private _ondata

_ondata: Array<dataCallback> = new Array<dataCallback>()

Private _ondrain

_ondrain: Array<notifyCallback> = new Array<notifyCallback>()

Private _onopen

_onopen: Array<notifyCallback> = new Array<notifyCallback>()

Private _onpause

_onpause: Array<notifyCallback> = new Array<notifyCallback>()

Private _onresume

_onresume: Array<notifyCallback> = new Array<notifyCallback>()

Private _promise

_promise: Promise<any>

Private _reject

_reject: function

Type declaration

    • (error: Error): void
    • Parameters

      • error: Error

      Returns void

Private _resolve

_resolve: function

Type declaration

    • (arg: any): void
    • Parameters

      • arg: any

      Returns void

Private _state

_state: State = State.RUNNING

Private _threshold

_threshold: number = 0

Private _waiting

_waiting: boolean = false

Protected _write

_write: dataCallback

Accessors

isClosed

  • get isClosed(): boolean

isClosing

  • get isClosing(): boolean

isOpening

  • get isOpening(): boolean

isRunning

  • get isRunning(): boolean

readable

  • get readable(): boolean

state

writable

  • get writable(): boolean

Methods

catch

close

data

Private dispatchQueue

drain

end

finally

  • finally(callback: any): Stream

open

pause

pipe

push

resume

setState

then

write

Generated using TypeDoc