RxJS：bindNodeCallback绑定多触发回调API仅触发一次问题求助

你遇到的问题核心在于Observable.bindNodeCallback的设计目标——它是专门为单次触发的Node.js风格回调（也就是调用一次callback就完成的场景，比如文件读取、单次HTTP请求）设计的，所以它只会捕获回调的第一次调用，后续的触发就会被忽略。

要让多次触发回调的API正确转为Observable，你需要手动创建Observable，在订阅逻辑里直接对接API的回调，每次回调触发时调用subscriber.next()来推送数据。具体实现如下：

// 手动创建Observable来适配多次回调的API
const obs = new Observable((subscriber) => {
  // 调用你的API，传入自定义回调
  api(params, (error, result) => {
    if (error) {
      // 如果有错误，推送错误通知并终止（可选，根据API行为调整）
      subscriber.error(error);
      return;
    }
    // 每次回调触发时，推送结果到订阅者
    subscriber.next(result);
    // 注意：不要调用subscriber.complete()，因为API会多次触发回调
  });

  // 可选：如果你的API支持取消监听，在这里返回清理函数，避免内存泄漏
  return () => {
    // 示例：假设API有取消订阅的方法
    // api.removeListener();
  };
});

// 订阅Observable，接收多次推送的数据
obs.subscribe({
  next: data => console.log('OBSERVABLE', data),
  error: err => console.error('API出错:', err)
});

补充说明 #

• bindNodeCallback内部逻辑是当回调第一次被调用时，就会自动调用complete()结束Observable，所以后续的回调触发自然不会被处理。
• 手动创建Observable时，你完全控制回调的处理逻辑，能适配任何多次触发的事件源（比如Pub/Sub、WebSocket消息这类持续推送的场景）。

内容的提问来源于stack exchange，提问作者jeanpaul62