Class MessageProcessor<Msg, HandlerOpts>

Processor of messages from an MessageSubscription.

Type Parameters

  • Msg = unknown

  • HandlerOpts = object

Hierarchy

Implements

Constructors

Properties

Accessors

Methods

Constructors

Properties

close: ((...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
consumer: MessageHandler<Msg, HandlerOpts>

Consumer of messages.

handle: undefined | Unsubscribe
start: ((...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
subscription: MessageSubscription<Msg, HandlerOpts>

MessageSubscription to consume.

Accessors

Methods

  • Returns Promise<void>

Generated using TypeDoc