Options
All
  • Public
  • Public/Protected
  • All
Menu

Class MetaStream<A, B>

see

metaStream for reference & examples.

Type parameters

  • A

  • B

Hierarchy

Index

Constructors

constructor

Properties

Optional __owner

__owner: ISubscription<any, any>

Protected cacheLast

cacheLast: boolean

closeIn

closeIn: CloseMode

closeOut

closeOut: CloseMode

doneRequested

doneRequested: boolean

emitLast

emitLast: boolean

factory

factory: Fn<A, Subscription<B, B>>

id

id: string

Protected last

last: any = ...

Optional parent

parent: ISubscription<any, A>

Protected state

state: State = ...

Optional stream

stream: Subscription<B, B>

Optional sub

sub: ISubscription<B, B>

Protected subs

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

Protected Optional wrapped

wrapped: Partial<ISubscriber<B>>

Protected Optional xform

xform: Reducer<B[], A>

Methods

deref

  • deref(): undefined | B

Protected detach

  • detach(force: boolean): void

Protected dispatch

  • dispatch(x: B): void

Protected dispatchTo

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

Protected dispatchXform

  • dispatchXform(x: A): void

Protected dispatchXformDone

  • dispatchXformDone(): boolean

Protected dispatchXformVals

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

done

  • done(): void

Protected ensureState

  • ensureState(): void

error

  • error(e: any): boolean

getState

map

next

  • next(x: A): 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