node.js - RxJS - 从 EventEmitter 的多个事件创建 Observable

Question

我有一个 node.js EventEmitter，它会引发以下事件:错误、消息。

有没有一种直接的方法可以从中创建 RxJS Observable？

即 next() 对 message 调用，error() 对 error 调用。

Answer 1

您可以像这样创建它:

const obs$ = Observable.create(observer => {
  emitter.on('message', val => observer.next(val));
  emitter.on('error', err => observer.error(err));
});

<小时/>

作为替代方案，您可以通过像这样构造和链接可观察量来做到这一点，但它的可读性显然较差:

const message$ = Observable.fromEvent(emitter, 'message');
const error$ = Observable.fromEvent(emitter, 'error');

const obs$ = Observable.merge(
  message$.catch(err => Observable.of(err)),
  error$.mergeMap(val => Observable.throw(val)),
);