Class SimpleMessageBus<Message>

Simple in-memory implementation of MessageBus.

Type Parameters

  • Message

Implements

Constructors

Properties

defaultTopic: string = 'message'

Name of the default topic.

dispatch: ((...args) => MaybePromise<void>) = ...

Type declaration

    • (...args): MaybePromise<void>
    • Wraps a MaybePromise-yielding coroutine (generator function) into a function that returns MaybePromise. This allows you to use maybeAsync/yield in a similar way to async/await, where yield maybePromise will return awaited / resolved value.

      Parameters

      Returns MaybePromise<void>

      Example

      const add = maybeAsync(function* (a: number, b: number) {
      const result1: number = yield Promise.resolve(a); // result1 === a
      const result2 = yield b; // result2 === b
      return result + result2;
      });
      const result = await add(1, 2); // result === 3
handlers: Map<string, MessageHandler<Message>[]> = ...

Methods

Generated using TypeDoc