我在Kotlin中编写一种方法:
fun fetchDepositSession(): Completable =
Observable.fromIterable(session.accounts)
.map(DepositSession::DepositAccount)
.toList()
.doOnSuccess(depositSession::depositAccounts::set)
.flatMapObservable(Observable::fromIterable)
.map(DepositSession.DepositAccount::account::get)
.toCompletable()
.flatMapObservable(Observable::fromIterable)
行导致错误:最佳答案
RxJava和Kotlin推断类型不能很好地工作。有一些问题,例如KT-13609和KT-14984。
请参阅与该问题相关的this question。还有一个issue in RxKotlin's Github在谈论它。
无论如何,您始终可以使用:
.flatMapObservable { Observable.fromIterable(it) }