Name of the default topic.
Readonly
defaultName of the default topic.
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.
Rest
...args: [message: Message, options?: MessageOptions]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
Private
Readonly
handlersPrivate
coOptional
options: MessageOptionsSubscribes to new messages and returns a handle to unsubscribe.
Optional
options: SubscribeOptions<Message, object>Generated using TypeDoc
Simple in-memory implementation of MessageBus.