Source MessageSubscription to consume.
Output MessageDispatcher to use.
Message handler.
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: [options?: AbortOptions]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
Protected
Readonly
consumerConsumer of messages.
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: [options?: AbortOptions]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
Protected
Readonly
subscriptionMessageSubscription to consume.
Returns if this has started.
Generated using TypeDoc
MessageProcessor that handles input message and transforms it to output message.