2694. 事件发射器

---

1.题目描述

class EventEmitter {
  constructor() {
    // 创建一个空对象 events，用于存储事件名称和对应的回调函数数组
    this.events = {};
  }
  // 接受两个参数，eventName 事件名称，callback 回调函数
  subscribe(eventName, callback) {
    // 如果 evnets 对象中不存在 eventName 对应的数组，则创建一个空数组
    if (!this.events[eventName]) {
      this.events[eventName] = [];
    }

    // 将回调函数添加到对应事件的数组中
    this.events[eventName].push(callback);

    // 返回一个包含 unsubscribe 方法的对象，以允许用户取消订阅
    const unsubscribe = () => {
      const index = this.events[eventName].indexOf(callback);
      if (index !== -1) {
        this.events[eventName].splice(index, 1);
      }
    };

    return { unsubscribe };
  }
  // 接受两个参数，eventName 事件名称和可选的 args 参数数组
  emit(eventName, args = []) {
    // 首先检查 events 对象中是否存在 eventName 对应的数组，如果不存在则返回一个空数组
    if (!this.events[eventName]) {
      return [];
    }

    const results = [];
    // 遍历 eventName 对应的数组，依次调用每个回调函数，并将 args 作为参数传递给它们
    // 将每个回调函数的返回值添加到一个结果数组中
    for (const callback of this.events[eventName]) {
      results.push(callback(...args));
    }
    // 返回结果数组
    return results;
  }
}

// 示例用法
const emitter = new EventEmitter();

// 订阅事件 "myEvent"
const subscription1 = emitter.subscribe("myEvent", (arg1, arg2) => {
  console.log(`Callback 1: ${arg1}, ${arg2}`);
});

// 另一个订阅同一个事件
const subscription2 = emitter.subscribe("myEvent", (arg1, arg2) => {
  console.log(`Callback 2: ${arg1}, ${arg2}`);
});

// 触发事件 "myEvent"，并传递参数
const results = emitter.emit("myEvent", ["Hello", "World"]);

console.log(results); // 输出结果数组

// 取消订阅第一个回调函数
subscription1.unsubscribe();

// 再次触发事件 "myEvent"
emitter.emit("myEvent", ["Goodbye", "EventEmitter"]);