MessageSubscription to consume.
Event store writer to use.
Function to translate incoming events for storage.
Function to translate incoming events for storage.
Optional options: AbortOptions & HandlerOptsWraps 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 persists message using an ObjectWriter.