将 Single<List<Maybe<Book>>> 转换为 Single<List<Book>>

Question

有人可以帮忙吗？

我有这些功能

fun getBooks(): Single<List<Book>> {
    return getCollections()
        .map {
            it.map(::collectonToBook)
        }
}

fun getCollections(): Single<List<Collection>> {
   return db.fetchCollections()
       .filter(::isBook)
}

fun collectonToBook(collection: Collection): Maybe<Book> {
    return collection.toBook()
}
            

问题是当我需要 Single<List<Book>> 时 getBooks 返回 Single<List<Maybe<Book>>>。我可以在流中做到这一点而不调用blockingGet吗？

Answer 1

试试这个：

getCollections()                        // Single<List<Collection>>
.flattenAsFlowable { it }               // Flowable<Collection>
.concatMapMaybe { collectonToBook(it) } // Flowable<Book>
.toList()                               // Single<List<Book>>

换句话说，将内部List 解包为其元素，将Collection 转换为Book，连接它们各自的Maybe 源，然后最后将Books 再次收集为List。