在 RxJava 和 RxScala 中转换 Observable
Transforming Observables in RxJava and RxScala
我有一个 Observable 发出如下条目列表：
val obsList: Observable[List[MyEntry] = Observable.from(getListEntry)
// getListEntry would give me a List[MyEntry]
我现在如何将内容通过管道传输到另一个接收 MyEntry 的 Observable 中？我的意思是，对于原始 Observable 中的每个条目，我需要将它们通过管道传输到另一个类型签名为：
的 Observable
Observable[MyEntry]
我知道怎么做了！我正在使用 Monifu 库！
所以，我会这样做：
Observable.fromIterable(listOfEntry)
我有一个 Observable 发出如下条目列表：
val obsList: Observable[List[MyEntry] = Observable.from(getListEntry)
// getListEntry would give me a List[MyEntry]
我现在如何将内容通过管道传输到另一个接收 MyEntry 的 Observable 中？我的意思是，对于原始 Observable 中的每个条目，我需要将它们通过管道传输到另一个类型签名为：
的 ObservableObservable[MyEntry]
我知道怎么做了！我正在使用 Monifu 库！
所以，我会这样做：
Observable.fromIterable(listOfEntry)