Method on

packages/core/src/utils/event-bus.ts:36–46

Subscribe to an event

(event: K, callback: EventCallback<K>)

  /** Subscribe to an event */
  on<K extends keyof EventMap>(event: K, callback: EventCallback<K>): () => void {
    if (!this.listeners.has(event)) {
      this.listeners.set(event, new Set());
    }
    this.listeners.get(event)!.add(callback as EventCallback<keyof EventMap>);

    // Return unsubscribe function
    return () => {
      this.listeners.get(event)?.delete(callback as EventCallback<keyof EventMap>);
    };
  }

  /** Subscribe to an event, auto-unsubscribe after first invocation */
  once<K extends keyof EventMap>(event: K, callback: EventCallback<K>): () => void {