Class Stream<T>

See

stream & reactive for reference & examples.

Type Parameters

  • T

Hierarchy (view full)

Implements

Constructors

Properties

__owner?: ISubscription<any, any>

Internal use only. Do not use.

_cancel: undefined | StreamCancel
_inited: boolean
cacheLast: boolean
closeIn: CloseMode
closeOut: CloseMode
id: string
last: any = SEMAPHORE
parent?: ISubscription<any, T>
state: State = State.IDLE
subs: Partial<ISubscriber<T>>[] = []
wrapped?: Partial<ISubscriber<T>>
xform?: Reducer<T, T[]>

Methods

Generated using TypeDoc