PersistentAI API Documentation / @persistentai/fireflow-types / EventManager
Class: EventManager
Defined in: packages/fireflow-types/src/flow/execution/runtime/event-manager.ts:21
Centralized event manager for the SP-tree execution engine.
In-memory only — owns event creation, queue publishing, and local subscriber notification. DBOS stream writes are handled externally by a workflow-level subscriber (engine.onAll()).
Constructors
Constructor
new EventManager(
executionId):EventManager
Defined in: packages/fireflow-types/src/flow/execution/runtime/event-manager.ts:33
Parameters
executionId
string
Returns
EventManager
Methods
close()
close():
Promise<void>
Defined in: packages/fireflow-types/src/flow/execution/runtime/event-manager.ts:136
Returns
Promise<void>
createEvent()
createEvent<
T>(type,data):ExecutionEventImpl<T>
Defined in: packages/fireflow-types/src/flow/execution/runtime/event-manager.ts:39
Type Parameters
T
T extends ExecutionEventEnum
Parameters
type
T
data
Returns
getEventQueue()
getEventQueue():
EventQueue<ExecutionEventImpl<ExecutionEventEnum>>
Defined in: packages/fireflow-types/src/flow/execution/runtime/event-manager.ts:132
Returns
EventQueue<ExecutionEventImpl<ExecutionEventEnum>>
on()
on<
T>(type,handler): () =>void
Defined in: packages/fireflow-types/src/flow/execution/runtime/event-manager.ts:84
Type Parameters
T
T extends ExecutionEventEnum
Parameters
type
T
handler
EventHandler<T>
Returns
():
void
Returns
void
onAll()
onAll(
handler): () =>void
Defined in: packages/fireflow-types/src/flow/execution/runtime/event-manager.ts:97
Parameters
handler
EventHandler
Returns
():
void
Returns
void
publish()
publish<
T>(type,data):Promise<void>
Defined in: packages/fireflow-types/src/flow/execution/runtime/event-manager.ts:57
Single publish method — pushes to in-memory queue + notifies local handlers. No DBOS writes here. The workflow-level subscriber handles that.
Type Parameters
T
T extends ExecutionEventEnum
Parameters
type
T
data
Returns
Promise<void>
setEventCallback()
setEventCallback(
_callback):void
Defined in: packages/fireflow-types/src/flow/execution/runtime/event-manager.ts:126
Parameters
_callback
unknown
Returns
void
setOnEventPublished()
setOnEventPublished(
hook):void
Defined in: packages/fireflow-types/src/flow/execution/runtime/event-manager.ts:122
For external hook (used by non-DBOS mode or tests).
Parameters
hook
(event) => Promise<void>
Returns
void
waitForPendingWrites()
waitForPendingWrites():
Promise<void>
Defined in: packages/fireflow-types/src/flow/execution/runtime/event-manager.ts:140
Returns
Promise<void>