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
});