Interface EventBuffer

Event buffer and subscription delivery engine.

interface EventBuffer {
    bufferAndDeliver(event: NostrEvent, senderId: string | null): void;
    clear(): void;
    deliverToSubscriptions(event: NostrEvent, senderId: string | null): void;
    getBufferedEvents(): readonly NostrEvent[];
    getSubscriptions(): Map<string, SubscriptionEntry>;
}

Index

Methods

bufferAndDeliver clear deliverToSubscriptions getBufferedEvents getSubscriptions

Methods

bufferAndDeliver

bufferAndDeliver(event: NostrEvent, senderId: string | null): void
Add an event to the ring buffer and deliver to matching subscriptions.
Parameters
- event: NostrEvent
- senderId: string | null
Returns void
- Defined in packages/runtime/src/event-buffer.ts:79

clear

clear(): void
Clear the buffer.

Returns void
- Defined in packages/runtime/src/event-buffer.ts:91

deliverToSubscriptions

deliverToSubscriptions(event: NostrEvent, senderId: string | null): void
Deliver an event to matching subscriptions without buffering.
Parameters
- event: NostrEvent
- senderId: string | null
Returns void
- Defined in packages/runtime/src/event-buffer.ts:82

getBufferedEvents

getBufferedEvents(): readonly NostrEvent[]
Get buffered events (for REQ replay).

Returns readonly NostrEvent[]
- Defined in packages/runtime/src/event-buffer.ts:88

getSubscriptions

getSubscriptions(): Map<string, SubscriptionEntry>
Get the current subscription map (for REQ handler to register subs).

Returns Map<string, SubscriptionEntry>
- Defined in packages/runtime/src/event-buffer.ts:85