@saflib/notify

---

Class: InProcessChangeEmitter

Single-process ChangeEmitter with per-org subscribers and a small ring buffer for Last-Event-ID reconnect replay.

Implements

• ChangeEmitter

Constructors

Constructor

new InProcessChangeEmitter(options): InProcessChangeEmitter

Parameters

Parameter	Type
options	InProcessChangeEmitterOptions

Returns

InProcessChangeEmitter

Methods

getEventsAfter()

getEventsAfter(orgId, lastEventId): ChangeEventWithId[]

Events strictly after lastEventId still held in the per-org ring buffer. Empty when the id is unknown, expired, or at the tip.

Parameters

Parameter	Type
orgId	string
lastEventId	string

Returns

ChangeEventWithId[]

Implementation of

ChangeEmitter.getEventsAfter

---

publish()

publish(event): void

Publish a change for the event's org_id channel.

Parameters

Parameter	Type
event	ChangeEvent

Returns

void

Implementation of

ChangeEmitter.publish

---

subscribe()

subscribe(orgId, listener): () => void

Subscribe to an org channel. Returns an unsubscribe function. Does not replay history — use getEventsAfter with Last-Event-ID for that.

Parameters

Parameter	Type
orgId	string
listener	ChangeEventListener

Returns

(): void

Returns

void

Implementation of

ChangeEmitter.subscribe