我想知道如何使用rxjava调用协同程序，而不使用任何作用域。如果我有
suspend fun fetchInfo() { //some code here }
它必须返回一个可观察的？？调用者应该能够指定正在运行的线程（即schedulers.io）我可能可以使用runblocking，但不知道如何连接所有内容。谢谢
cygmwpex1#
使用 rxSingle , rxObservable 功能
rxSingle
rxObservable
import kotlinx.coroutines.rx3.rxObservable import kotlinx.coroutines.rx3.rxSingle rxSingle { fetchInfo() } rxObservable { send(fetchInfo()) }
https://github.com/hoc081098/comicreaderapp_mvi_coroutine_rxkotlin_jetpack/blob/f4e89036b934f8233d6d6ded941b19b702467405/app/src/main/java/com/hoc/comicapp/data/repository/comicrepository1impl.kt#l27https://github.com/hoc081098/comicreaderapp_mvi_coroutine_rxkotlin_jetpack/blob/f4e89036b934f8233d6d6ded941b19b702467405/app/src/main/java/com/hoc/comicapp/ui/search_comic/searchcomicinteractorimpl.kt#l20
1条答案
按热度按时间cygmwpex1#
使用
rxSingle,rxObservable功能https://github.com/hoc081098/comicreaderapp_mvi_coroutine_rxkotlin_jetpack/blob/f4e89036b934f8233d6d6ded941b19b702467405/app/src/main/java/com/hoc/comicapp/data/repository/comicrepository1impl.kt#l27
https://github.com/hoc081098/comicreaderapp_mvi_coroutine_rxkotlin_jetpack/blob/f4e89036b934f8233d6d6ded941b19b702467405/app/src/main/java/com/hoc/comicapp/ui/search_comic/searchcomicinteractorimpl.kt#l20