Options
All
  • Public
  • Public/Protected
  • All
Menu

Class StreamSync<A, B>

Type parameters

Hierarchy

Implements

Index

Constructors

constructor

Properties

Protected cacheLast

cacheLast: boolean

clean

clean: boolean

closeIn

closeIn: CloseMode

closeOut

closeOut: CloseMode

id

id: string

idSources

idSources: Map<string, ISubscribable<any>>

maps real source IDs to their actual input

invRealSourceIDs

invRealSourceIDs: Map<string, string>

maps real src.id to (potentially aliased) input IDs

Protected last

last: any

Protected Optional parent

parent: ISubscribable<any>

psync

psync: PartitionSync<[string, any]>

realSourceIDs

realSourceIDs: Map<string, string>

maps (potentially aliased) input IDs to their actual src.id

sources

sources: Map<ISubscribable<any>, Subscription<any, [string, any]>>

maps actual inputs to their virtual input subs

Protected state

state: State = State.IDLE

Protected subs

subs: ISubscriber<B>[]

Protected Optional xform

xform: Reducer<B[], any>

Methods

add

addAll

  • addAll(src: Partial<A>): void

Protected addWrapped

Protected cleanup

  • cleanup(): void

deref

  • deref(): B | undefined

Protected dispatch

  • dispatch(x: B): void

done

  • done(): void

Protected ensureState

  • ensureState(): void

error

  • error(e: any): void

getSourceForID

getSources

  • getSources(): A

getState

map

Protected markDone

next

  • next(x: any): void

remove

removeAll

removeAllIDs

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

removeID

  • removeID(id: string): boolean

subscribe

subscribeAll

transform

  • transform<C>(a: Transducer<B, C>, opts?: Partial<CommonOpts>): Subscription<B, C>
  • transform<C, D>(a: Transducer<B, C>, b: Transducer<C, D>, opts?: Partial<CommonOpts>): Subscription<B, D>
  • transform<C, D, E>(a: Transducer<B, C>, b: Transducer<C, D>, c: Transducer<D, E>, opts?: Partial<CommonOpts>): Subscription<B, E>
  • transform<C, D, E, F>(a: Transducer<B, C>, b: Transducer<C, D>, c: Transducer<D, E>, d: Transducer<E, F>, opts?: Partial<CommonOpts>): Subscription<B, F>

unsubscribe

Generated using TypeDoc