使用没有范围的 RxJava 调用协程

Question

我想知道如何在不使用任何作用域的情况下使用 RxJava 调用协程。

如果我有

suspend fun fetchInfo()  {
    //some code here
}

• 它必须返回一个 Observable 吗？？
• 调用者应该能够指定正在运行的线程（即 Schedulers.IO ）
• 我或许可以使用 runBlocking，但不确定如何连接所有内容。

谢谢

Answer 1

使用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#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