createEventEmitter()

createEventEmitter(config?): EventEmitter

Defined in: event-emitter.ts:180

Create an event emitter for routing AgentFlow events to writers and subscribers.

The emitter is a simple pub/sub — no queuing, no retry, no backpressure. Writer errors are reported via the onError callback and do not block emission.

Parameters

Parameter	Type	Description
config?	EventEmitterConfig	Optional configuration with writers and error handler.

Returns

EventEmitter

An EventEmitter with emit and subscribe methods.

Example

const emitter = createEventEmitter({
  writers: [jsonWriter],
  onError: (err) => console.error('Event write failed:', err),
});

emitter.subscribe((event) => console.log('Event:', event.eventType));

await emitter.emit(createExecutionEvent(graph));