在拦截器中订阅时没有任何反应

// 示例代码：假设我们使用的是一个简单的事件系统
const eventSystem = {
  events: {},
  subscribe(event, callback) {
    if (!this.events[event]) {
      this.events[event] = [];
    }
    this.events[event].push(callback);
  },
  publish(event, data) {
    if (this.events[event]) {
      this.events[event].forEach(callback => callback(data));
    }
  }
};

// 在拦截器中订阅事件
eventSystem.subscribe('myEvent', (data) => {
  console.log('Event received:', data);
});

// 触发事件
eventSystem.publish('myEvent', { message: 'Hello, world!' });

// 示例代码：使用Promise处理异步事件
eventSystem.subscribe('asyncEvent', async (data) => {
  console.log('Async event received:', data);
  await someAsyncFunction(data);
});

function someAsyncFunction(data) {
  return new Promise((resolve) => {
    setTimeout(() => {
      console.log('Async function completed:', data);
      resolve();
    }, 1000);
  });
}

eventSystem.publish('asyncEvent', { message: 'Async hello!' });

// 示例代码：假设我们使用的是一个HTTP拦截器
const express = require('express');
const app = express();

app.use((req, res, next) => {
  // 订阅事件
  eventSystem.subscribe('requestEvent', (data) => {
    console.log('Request event received:', data);
  });

  // 继续处理请求
  next();
});

app.get('/', (req, res) => {
  // 触发事件
  eventSystem.publish('requestEvent', { path: req.path });
  res.send('Hello, world!');
});

app.listen(3000, () => {
  console.log('Server is running on port 3000');
});

// 示例代码：添加日志
eventSystem.subscribe('myEvent', (data) => {
  console.log('Event received:', data);
});

eventSystem.publish('myEvent', { message: 'Hello, world!' });