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