Jigsaw1601 / eventbus.ts

type Topics = { "event.post": EventPost1Data; }; type Callbacks<T extends keyof Topics> = (data: Topics[T]) => void; class EventBus<T extends keyof Topics> { private subscribers: { [K in T]?: Callbacks<K>[] } = {}; subscribe<K extends T>(topic: K, callback: Callbacks<K>): void { if (!this.subscribers[topic]) { this.subscribers[topic] = []; } this.subscribers[topic]?.push(callback); } unsubscribe<K extends T>(topic: K, callback: Callbacks<K>): void { const callbacks = this.subscribers[topic]; if (callbacks) { this.subscribers[topic] = callbacks.filter(cb => cb !== callback); } } publish<K extends T>(topic: K, payload: Topics[K]): void { const callbacks = this.subscribers[topic]; if (callbacks) { for (const callback of callbacks) { callback(payload); } } } } // Define topics and their corresponding payload types export const msgbus = new EventBus();