Options
All
  • Public
  • Public/Protected
  • All
Menu

Class PubSub<A, B>

Type parameters

  • A

  • B

Hierarchy

Implements

Index

Constructors

constructor

Properties

Protected cacheLast

cacheLast: boolean

closeIn

closeIn: CloseMode

closeOut

closeOut: CloseMode

id

id: string

Protected last

last: any

Protected Optional parent

parent: ISubscribable<A>

Protected state

state: State = State.IDLE

Protected subs

subs: ISubscriber<B>[]

topicfn

topicfn: Fn<B, any>

topics

topics: EquivMap<any, Subscription<B, B>>

Protected Optional xform

xform: Reducer<B[], A>

Methods

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

getState

map

next

  • next(x: A): void

subscribe

subscribeAll

subscribeTopic

transform

unsubscribe

unsubscribeTopic

  • unsubscribeTopic(topicID: any, sub: Subscription<B, any>): boolean

Generated using TypeDoc