如何在拦截器类中使用catchError发送正确的响应

const express = require('express');
const { Observable } = require('rxjs');

class ErrorHandlerInterceptor {
  intercept(req, res, next) {
    // 执行业务逻辑
    Observable.of('Some data') // 示例业务逻辑，返回数据
      .map(data => {
        // 进行其他处理
        throw new Error('Some error'); // 示例出错
        return data;
      })
      .catch(error => {
        // 发送错误响应
        res.status(500).send({
          message: 'An error occurred',
          code: 500,
        });
        return Observable.empty(); // 可选操作，中断后续操作
      })
      .subscribe(data => {
        // 发送正确的响应
        res.status(200).send(data);
      });
  }
}

const app = express();
app.use(new ErrorHandlerInterceptor().intercept);
app.listen(3000, () => {
  console.log('Server is running on port 3000');
});