Interface OutboxSubscriptionSink

Sink an OutboxRouter streams subscription lifecycle through.

interface OutboxSubscriptionSink {
    closed(reason?: string): void;
    eose(): void;
    event(event: NostrEvent, relay?: string): void;
}

Index

Methods

closed eose event

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:134

eose

eose(): void
Signal end-of-stored-events.

Returns void
- Defined in packages/services/src/outbox-service.ts:132

event

event(event: NostrEvent, relay?: string): void
Deliver a matching event; relay is the relay it was observed on, when known.
Parameters
- event: NostrEvent
- Optionalrelay: string
Returns void
- Defined in packages/services/src/outbox-service.ts:130