EventEmitter 的原理是什么？手写发布订阅

import { EventEmitter } from 'node:events'

const emitter = new EventEmitter()
emitter.on('data', () => console.log('A'))
emitter.on('data', () => console.log('B'))
console.log('before')
emitter.emit('data')
console.log('after')
// 输出 before、A、B、after：emit 是同步的

class MyEmitter {
  #events = new Map() // 事件名 -> 监听器数组

  on(name, listener) {
    if (!this.#events.has(name)) this.#events.set(name, [])
    this.#events.get(name).push(listener)
    return this // 支持链式调用
  }

  once(name, listener) {
    const wrapper = (...args) => {
      this.off(name, wrapper) // 先移除再执行：监听器里再次 emit 也不会重复触发
      listener.apply(this, args)
    }
    wrapper.listener = listener // 记住原函数，off(name, listener) 时也能找到它
    return this.on(name, wrapper)
  }

  off(name, listener) {
    const list = this.#events.get(name)
    if (!list) return this
    // 从后往前找，和 Node.js 一样只移除最近添加的一个
    for (let i = list.length - 1; i >= 0; i--) {
      if (list[i] === listener || list[i].listener === listener) {
        list.splice(i, 1)
        break
      }
    }
    if (list.length === 0) this.#events.delete(name)
    return this
  }

  emit(name, ...args) {
    const list = this.#events.get(name)
    if (!list) {
      if (name === 'error') throw args[0] instanceof Error ? args[0] : new Error(`未处理的 error 事件：${args[0]}`)
      return false
    }
    // 先复制再遍历：once 的包装函数执行时会修改原数组，直接遍历会跳过下一个监听器
    for (const listener of [...list]) listener.apply(this, args)
    return true
  }
}
const bus = new MyEmitter()
const hello = (name) => console.log('hello', name)
bus.once('greet', hello)
bus.on('greet', (name) => console.log('hi', name))
bus.emit('greet', 'Tom')   // hello Tom、hi Tom
bus.emit('greet', 'Jerry') // hi Jerry：once 的监听器已经被移除