Class PublisherSubscriber

Hierarchy

PublisherSubscriber

Implements

IBus

Index

Constructors

constructor

Properties

Methods

Constructors

constructor

new PublisherSubscriber(): PublisherSubscriber

- Defined in PublisherSubscriber.ts:20
Returns PublisherSubscriber

Properties

Private logger

logger: ILogger

messageCounter

messageCounter: number = 0

Private subjectBus

subjectBus: Subject<any>

Methods

asObservable

asObservable<T>(topic: object | string): Observable<T>

- Defined in PublisherSubscriber.ts:69
Type parameters
- T
Parameters
- topic: object | string
Returns Observable<T>

publish

publish<T>(message: T, topic?: string): void

- Defined in PublisherSubscriber.ts:29
Type parameters
- T
Parameters
- message: T
- Optional topic: string
Returns void

publishAsync

publishAsync<T>(message: T, topic?: string): Promise<void>

- Defined in PublisherSubscriber.ts:43
Type parameters
- T
Parameters
- message: T
- Optional topic: string
Returns Promise<void>

subscribe

subscribe<T>(topic: object | string, handler: function): Subscription

- Defined in PublisherSubscriber.ts:55
Type parameters
- T
Parameters
- topic: object | string
- handler: function
  - - (data: T): void
    - Parameters
      - data: T
      Returns void
Returns Subscription

subscribeAsync

subscribeAsync<T>(topic: object | string, handler: function): Subscription

- Defined in PublisherSubscriber.ts:62
Type parameters
- T
Parameters
- topic: object | string
- handler: function
  - - (data: T): Promise<void>
    - Parameters
      - data: T
      Returns Promise<void>
Returns Subscription

topicMatches

topicMatches(value: string, topic: string): boolean

- Defined in PublisherSubscriber.ts:85
Parameters
- value: string
- topic: string
Returns boolean

Generated using TypeDoc