Interface OutboxSubscriptionSink

Sink an OutboxRouter streams subscription lifecycle through.

interface OutboxSubscriptionSink {
closed(reason?: string): void;
event(result: RelayEventResult): void;
}

Index

Methods

Methods

closed

closed(reason?: string): void
Signal that the subscription was closed upstream; reason is optional.
Parameters
- Optionalreason: string
Returns void
- Defined in packages/services/src/outbox-service.ts:136

event

event(result: RelayEventResult): void
Deliver a matching event result.
Parameters
- result: RelayEventResult
Returns void
- Defined in packages/services/src/outbox-service.ts:134