Options
All
  • Public
  • Public/Protected
  • All
Menu

Class StreamMerge<A, B>

see

merge 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

id

id: string

Protected last

last: any = ...

Optional parent

parent: ISubscription<any, A>

sources

sources: Map<ISubscribable<A>, ISubscription<A, any>>

Protected state

state: State = ...

Protected subs

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

Protected Optional wrapped

wrapped: Partial<ISubscriber<B>>

Protected Optional xform

xform: Reducer<B[], A>

Methods

add

addAll

deref

  • deref(): undefined | B

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

Protected markDone

next

  • next(x: A): void

Protected release

  • release(): void

remove

removeAll

removeAllIDs

  • removeAllIDs(ids: Iterable<string>): boolean

removeID

  • removeID(id: string): boolean

Protected setState

  • setState(state: State): void

subscribe

transform

Protected unhandledError

  • unhandledError(e: any): boolean

unsubscribe

Protected unsubscribeChild

Protected unsubscribeSelf

  • unsubscribeSelf(): boolean

Generated using TypeDoc