如何使用 RxAndroid 压缩 Kotlin 语言中的几个 observable

Question

我有一些问题。我是 RxJava/RxKotlin/RxAndroid 的初学者，不了解某些功能。例如：

import rus.pifpaf.client.data.catalog.models.Category
import rus.pifpaf.client.data.main.MainRepository
import rus.pifpaf.client.data.main.models.FrontDataModel
import rus.pifpaf.client.data.product.models.Product
import rx.Observable
import rx.Single
import rx.lang.kotlin.observable
import java.util.*


class MainInteractor {

    private var repository: MainRepository = MainRepository()

    fun getFrontData() {

        val cats = getCategories()
        val day = getDayProduct()
        val top = getTopProducts()

        return Observable.zip(cats, day, top, MainInteractor::convert)
    }

    private fun getTopProducts(): Observable<List<Product>> {
        return repository.getTop()
                .toObservable()
                .onErrorReturn{throwable -> ArrayList() }

    }

    private fun getDayProduct(): Observable<Product> {
        return repository.getSingleProduct()
                .toObservable()
                .onErrorReturn{throwable -> Product()}

    }

    private fun getCategories(): Observable<List<Category>> {
        return repository.getCategories()
                .toObservable()
                .onErrorReturn{throwable -> ArrayList() }
    }

    private fun convert(cats: List<Category>, product: Product, top: List<Product>): FrontDataModel {

    }
}

然后我使用 MainInteractor::convert Android studio 接下来告诉我

我尝试了很多变体并试图理解它想要什么，但没有成功。请帮助我...最好的问候。

Answer 1

只需将函数引用替换为 lambda：

return Observable.zip(cats, day, top, { c, d, t -> convert(c, d, t) })

并且不要忘记显式声明函数的 return 类型：

fun getFrontData(): Observable<FrontDataModel> {
    ...

Answer 2

您还可以在 lambda 中显式指定 Function3 类型 Like :

Observable.zip(cats,
               day,
               top,
               Function3<List<Product>, Product, List<Category>, FrontDataModel> 
                         { cats, day, top -> convert(cats, day, top) }

并使用 IntelliJ idea 快捷键 alt+enter 显示更多操作并更改高阶函数的显示格式。

为什么是 Function3？

遵循功能接口，如果它有两个输入参数，它是一个 BiFunction and if it has 3 Inputs it's a Function3 并且列表还在继续。

Answer 3

此代码适用于 RXJAVA2

    for (i in dbCharacters) {
           // LoadImageToDBS(getApplication<Application>().applicationContext, i, this)
            //   charList.characterList[i.id!!].imageRawData = dbCharacters[i.id!!].imageRawData

            observable =
                    fetcher.loadImage(i.url)
                            .doOnSubscribe {
                                disposable.add(it)
                            }

            singleImageList.add(observable)

            observable.subscribe(object : DisposableSingleObserver<Bitmap>() {
                override fun onSuccess(t: Bitmap) {
                    Log.d("Image", "onSuccess")
                    i.imageRawData = bitMapToString(t)
                    updateCharacter(i)
                }

                override fun onError(e: Throwable) {
                    Log.d("Image Loading Error",e.message)
                }

            })
      }

        Single.zip(singleImageList, { args -> Arrays.asList(args) })
                .subscribe(
                        {
                            Log.d("Zip", "Zip Success")
                            countryLoadError.value = false
                            loading.value = false
                        },{
                    val c = it
                }
                )

如何使用 RxAndroid 压缩 Kotlin 语言中的几个 observable

How to zip few observables in Kotlin language with RxAndroid

android

kotlin

rx-java

rx-android

rx-kotlin