Dartlang rxdart - 合并不同类型的流

Question

这是我的用例:

我有两个不同的Observables:

Observable<MobileAdEvent> adEventStream;
Observable<Color> colorStream;

当这两者中的任一个发出事件时，我需要收到通知。 zipWith 对我不起作用，因为它会等到两个流都有一个事件要发出。 mergeWith 似乎也不起作用，因为它希望两个流都来自同一类型。任何提示将不胜感激，谢谢。

Answer 1

你想要的是combineLatest运算符

Observable<Foo> foo;
Observable<Bar> bar;

final output = Observable.combineLatest2(foo, bar, (Foo foo, Bar bar) {
  // TODO: somehow merge them
});