src/core/event-bus.js


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32

export class EventBus {
    constructor() {
        this.listeners = new Map();
    }

    on(eventName, listener) {
        if (!this.listeners.has(eventName)) {
            this.listeners.set(eventName, new Set());
        }

        const listeners = this.listeners.get(eventName);
        listeners.add(listener);

        return () => {
            listeners.delete(listener);
            if (listeners.size === 0) {
                this.listeners.delete(eventName);
            }
        };
    }

    emit(eventName, payload) {
        const listeners = this.listeners.get(eventName);
        if (!listeners) {
            return;
        }

        for (const listener of listeners) {
            listener(payload);
        }
    }
}