Class AsyncObservable<T>

Coordinates async subscriber actions with publish events

Type Parameters

T

Hierarchy (View Summary)

BaseObservable<T>
- AsyncObservable

Implements

IAsyncObservable<T>

Index

Constructors

Properties

active CurrentIssue? subscribers

Methods

Cancel Discontinue Order Publish Reinstate Subscribe

Constructors

constructor

new AsyncObservable<T>(): AsyncObservable<T>
Type Parameters
- T
Returns AsyncObservable<T>
Inherited from BaseObservable.constructor

Properties

`Protected`active

active: boolean = true

`Optional`CurrentIssue

CurrentIssue?: T

`Protected`subscribers

subscribers: Map<string, (content?: T) => void> = ...

Methods

Cancel

Cancel(subscriptionId: string): void
Cancel an existing subscription by passing the id returned in the subscribe call
Parameters
- subscriptionId: string
Returns void
Implementation of IAsyncObservable.Cancel
Inherited from BaseObservable.Cancel
- Defined in src/Patterns/Observable/BaseObservable.ts:10

Discontinue

Discontinue(): void
Prevents future publish events from calling subscribers

Returns void
Implementation of IAsyncObservable.Discontinue
Inherited from BaseObservable.Discontinue
- Defined in src/Patterns/Observable/BaseObservable.ts:14

Order

Order(
func: (content?: T) => Promise<void>,
useCurrentIssue?: boolean,
): Promise<void>
A single issue subscription. Once the function for an order fires, it is automatically canceled
Parameters
- func: (content?: T) => Promise<void>
- useCurrentIssue: boolean = true
  Determines if the order can be filled by the current issue
Returns Promise<void>
Implementation of IAsyncObservable.Order
- Defined in src/Patterns/Observable/AsyncObservable.ts:18

Publish

Publish(content?: T): Promise<void>
Signal a publish event to subscribers with the given content
Parameters
- Optionalcontent: T
Returns Promise<void>
Implementation of IAsyncObservable.Publish
Overrides BaseObservable.Publish
- Defined in src/Patterns/Observable/AsyncObservable.ts:33

Reinstate

Reinstate(): void
Resumes calling subscribers on publish events

Returns void
Implementation of IAsyncObservable.Reinstate
Inherited from BaseObservable.Reinstate
- Defined in src/Patterns/Observable/BaseObservable.ts:18

Subscribe(
func: (content?: T) => Promise<void>,
useCurrentIssue?: boolean,
): Promise<string>
Specify an async function to fire on future publish events | id returned allows caller to cancel subscription
Parameters
- func: (content?: T) => Promise<void>
- useCurrentIssue: boolean = true
Returns Promise<string>
Implementation of IAsyncObservable.Subscribe
- Defined in src/Patterns/Observable/AsyncObservable.ts:7