/* * Необходимо реализовать EventEmitter. * С методами emit и on. * * on(eventName: string | Symbol, callback: (payload?: any) => void): * () => void; * Принимает eventName с названием события и функцию callback. * Функция выполняет подписку на событие. * Результатом выполнения функции должна быть функция отписки. * * emit(eventName: string | Symbol, payload?: any): void * Принимает eventName с названием события и payload который будет * передан каждому слушателю eventName; Функция выполняет вызов события. * В случае если слушатель не найден, должен выкинуть исключение * * ------------------------------------------------------ * * Пример: * const myEmitter = new EventEmitter(); * * const unSubscribe = myEmitter.on('event', (payload) => { * console.log('an event occurred!!!', payload); */
Ответ от нейросети
sobes.tech AI
typescript class EventEmitter { private events: Map<string | Symbol, Set<(payload?: any) => void>> = new Map();
on(eventName: string | Symbol, callback: (payload?: any) => void): () => void { if (!this.events.has(eventName)) { this.events.set(eventName, new Set()); } const listeners = this.events.get(eventName)!; listeners.add(callback);
// Возвращаем функцию отписки
return () => {
listeners.delete(callback);
if (listeners.size === 0) {
this.events.delete(eventName);
}
};
}
emit(eventName: string | Symbol, payload?: any): void {
const listeners = this.events.get(eventName);
if (!listeners || listeners.size === 0) {
throw new Error(No listeners for event: ${String(eventName)});
}
for (const listener of listeners) {
listener(payload);
}
}
}
// Пример использования: const myEmitter = new EventEmitter();
const unSubscribe = myEmitter.on('event', (payload) => { console.log('an event occurred!!!', payload); });
myEmitter.emit('event', { data: 123 });
unSubscribe();
// После отписки вызов emit выбросит ошибку // myEmitter.emit('event');
В этом решении:
- Используется `Map` для хранения множества слушателей по имени события.
- Метод `on` добавляет слушателя и возвращает функцию отписки.
- Метод `emit` вызывает все слушатели события, если они есть, иначе выбрасывает ошибку.