如何从订阅或地图返回 Observable？

Question

我想在Subscribe函数中返回Observable，但是看了文档说不可能。 所以我尝试通过使用地图功能来做到这一点。但是，它产生了错误。

这是代码：

interface DataSource {

    fun getItem() : Observable<List<RetroCrypto>>
}

//

object RemoteDataSource : DataSource {

private val myCompositeDisposable by lazy { CompositeDisposable() }

override fun getItem() : Observable<List<RetroCrypto>> {

    val retrofit = RetroClient.getRetrofit()
    val requestInterface = retrofit.create(GetData::class.java)

    myCompositeDisposable.add(requestInterface.getData()
        // Send the Observable’s notifications to the main UI thread
        .observeOn(AndroidSchedulers.mainThread())
        // Subscribe to the Observer away from the main UI thread
        .subscribeOn(Schedulers.io())
        .map { return it }

    )
}

}

getRetrofit 是构建改造实例的方法。

我不知道为什么上面的代码会产生错误。

错误是

1. Return is not allowed here

2. Type mismatch. Required : Observable<List<RetroCrypto>> , Found : List<RetroCrypto>

如何修复代码？

Answer 1

在map 的 lambda 中，您可以在 Observable 中找到元素，因此在您的情况下，it 似乎是 List<RetroCrypto>。 如果您想返回Observable，您必须执行以下操作：

object RemoteDataSource : DataSource {

    private val myCompositeDisposable by lazy { CompositeDisposable() }

    override fun getItem(): Observable<List<RetroCrypto>> {

        val retrofit = RetroClient.getRetrofit()
        val requestInterface = retrofit.create(GetData::class.java)

        val observable = requestInterface.getData()
                // Send the Observable’s notifications to the main UI thread
                .observeOn(AndroidSchedulers.mainThread())
                // Subscribe to the Observer away from the main UI thread
                .subscribeOn(Schedulers.io())

        return observable
    }
}

注意：您只有在订阅后才能添加到myCompositeDisposable，因此您必须在此功能之外执行myCompositeDisposable.add。