asynchronous - rxjava合并不同类型的可观察量

Question

我是 rxjava 新手。我需要组合两个发出不同类型对象的可观察对象。类似 Observable<Milk>和Observable<Cereals>并得到 Observable<CerealsWithMilk> 。我找不到任何类似这样的运算符(operator)。做这样的事情的 rx 方式是什么？请注意Milk和Cereals是异步的。

Answer 1

如果不确切知道您需要什么，很难说，但可能 zip()或combineLatest() .

zip将同时采用 Observable<Milk>和Observable<Cereals>让你将它们组合成CerealsWithMilk通过提供的函数。这会发出一个新的 CerealsWithMilk每次您获得两者 Milk 和 Cereals .

combineLatest类似于 zip除非它会发出一个新的 CerealsWithMilk即使只是一个新的Milk 或只是一个新的Cereals被发射。