Options
All
  • Public
  • Public/Protected
  • All
Menu

Class Stream<T>

see

stream & reactive for reference & examples.

Type parameters

  • T

Hierarchy

Implements

Index

Constructors

constructor

Properties

Optional __owner

__owner: ISubscription<any, any>

Internal use only. Do not use.

Protected _cancel

_cancel: undefined | StreamCancel

Protected _inited

_inited: boolean

Protected cacheLast

cacheLast: boolean

closeIn

closeIn: CloseMode

closeOut

closeOut: CloseMode

id

id: string

Protected last

last: any = ...

Optional parent

parent: ISubscription<any, T>

Optional src

src: StreamSource<T>

Protected state

state: State = ...

Protected subs

subs: Partial<ISubscriber<T>>[] = ...

Protected Optional wrapped

wrapped: Partial<ISubscriber<T>>

Protected Optional xform

xform: Reducer<T[], T>

Methods

cancel

  • cancel(): void

deref

  • deref(): undefined | T

Protected dispatch

  • dispatch(x: T): void

Protected dispatchTo

  • dispatchTo(type: "error" | "next" | "done", x?: T): boolean

Protected dispatchXform

  • dispatchXform(x: T): void

Protected dispatchXformDone

  • dispatchXformDone(): boolean

Protected dispatchXformVals

  • dispatchXformVals(acc: T[] | Reduced<T[]>): boolean

done

  • done(): void

Protected ensureState

  • ensureState(): void

error

  • error(e: any): boolean
  • Error handler, which will be called to handle any uncaught errors while executing ISubscriber.next or a transducer function attached to the Subscription wrapping this subscriber. The error handler must return true to indicate the error could be successfully handled/recovered from. If false, the subscription will go into State.ERROR and stops processing any further values (plus might trigger recursive teardown of the upstream dataflow topology).

    Parameters

    • e: any

    Returns boolean

getState

map

next

  • next(x: T): void

Protected release

  • release(): void

Protected setState

  • setState(state: State): void

subscribe

transform

Protected unhandledError

  • unhandledError(e: any): boolean

unsubscribe

Protected unsubscribeChild

Protected unsubscribeSelf

  • unsubscribeSelf(): boolean

Generated using TypeDoc