这真的是从事件回调中获取 Rx.Observable 的最佳方式吗?

Is this really the best way to get a Rx.Observable from an event callback?

本文关键字：Observable Rx 最佳 方式吗 获取 真的 事件 回调      更新时间：2023-09-26

我想从数据映射库中获取事件流，但由于该库并没有真正考虑响应式编程，因此很难将任何发出的事件从它映射到可观察量。到目前为止，我最好的尝试是这个，但它感觉不是那么习惯。这是我能做的最好的事情，还是我可能缺少一些基本的 RxJs 结构，可以使其更好/更简单/更具可读性？

import Rx from 'rx';
import {EventEmitter} from 'events';
import Datamap from 'datamaps';
const eventEmitter = new EventEmitter();
const mapEvents$ = Rx.Observable.fromEvent(
  eventEmitter,
  'mapEvent'
)
const map = new Datamap({
  element: document.getElementById('map'),
  done: (datamap) => {
    datamap.svg
      .selectAll('.datamaps-subunit')
      .on('mouseover', (o) => {
        eventEmitter.emit('mapEvent', o);
      });
  }
});

看起来您正在使用事件发射器作为事件总线，但我们已经有您可以使用的主题。主体既是观察者又是可观察量，这意味着您可以对它们调用onNext以给他们下一个事件，并且可以在可观察序列上使用运算符。

简单地说，我会把它重写成这样：

import Rx from 'rx';
import Datamap from 'datamaps';
const datamapsSubject = new Rx.Subject();
const map = new Datamap({
  element: document.getElementById('map'),
  done: (datamap) => {
    datamap.svg
      .selectAll('.datamaps-subunit')
      .on('mouseover', (o) => {
        datamapsSubject.onNext(o);
      });
  }
});

如果您需要可以在订阅时构建并在处置/取消订阅时销毁的东西，您也可以考虑 Observable.create，但看起来您现在只针对一个div 元素。

相关文章：