Class AsyncObservable<T>

Coordinates async subscriber actions with publish events

Type Parameters

T

Hierarchy (view full)

BaseObservable<T>
- AsyncObservable

Implements

IAsyncObservable<T>

Index

Constructors

Properties

CurrentIssue? active 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

`Optional` CurrentIssue

CurrentIssue?: T

`Protected` active

active: boolean = true

`Protected` subscribers

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

Type declaration

- (content?): void
- Parameters
  - Optional content: T
  Returns void

Methods

Cancel

Cancel(subscriptionId): 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, useCurrentIssue?): Promise<void>
A single issue subscription. Once the function for an order fires, it is automatically canceled
Parameters
- func: ((content?) => Promise<void>)
  - - (content?): Promise<void>
    - Parameters
      Optional content: T
      Returns 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?): Promise<void>
Signal a publish event to subscribers with the given content
Parameters
- Optional content: 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

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

Generated using TypeDoc