@sozai/event

Typed event emitter with built-in stream bridging and on/once/emit/fire plus source/sink views.

Installation

pnpm add @sozai/event

Usage

import { EventEmitter } from '@sozai/event'

type Events = {
  data: { value: number }
  done: void
}

const emitter = new EventEmitter<Events>()

// Subscribe; `off()` unsubscribes
const off = emitter.on('data', (e) => console.log(e.value))

await emitter.emit('data', { value: 42 }) // awaits listeners, rethrows failures
emitter.fire('done')                      // fire-and-forget, errors swallowed

off()

Also provides once, readable/writable stream bridges, and the listen-only EventsSource / write-only EventsSink views — see the event reference (part of the sozai:dataflow skill) for the full API.