使用Rxjava进行改型

Question

1. 首先，如果我对Rxjava的理解有错，请告诉我。
2. 既然我们已经使用API查询使用referfit过滤了数据，那么对已经获得的数据进行操作有什么需要
3. 为什么在RXJava中使用客户接口对象？因此，我们将其用于观察者或onNext（）的位置。
4. Rxjava是否也有助于检索目的，或者它只是对已经获得的数据进行操作？

Answer 1

RXJava可以帮助您进行线程处理，并将其转换为现有的反应性代码。

它使用flowable/observable/single来获取数据（例如，如果在流中有许多数据），它允许使用flowable进行反压。

它还允许您使用基本的反应性的东西，比如在不同的线程中有请求，然后您的观察。

这也意味着您可以将结果/请求作为反应流和映射/转换/...以及RxJava的任何可能。

1）首先，如果我对RXJava的理解有什么错误，请告诉我。

RxJava代表反应式开发。它使用一种基于函数式编程的通用“编码风格”。

2）当我们已经使用API查询使用referfit过滤数据时，对已经获得的数据进行操作有什么需要

因为它是一个拦截器，所以它将“现有”数据转换为反应流。它对已经获得的数据进行操作。至少在这种情况下。

例如（Kotlin）：

    var service = Retrofit.Builder()
            .addCallAdapterFactory(RxJava2CallAdapterFactory.createWithScheduler(Schedulers.newThread()))
            .addCallAdapterFactory(ObserveOnMainCallAdapterFactory(AndroidSchedulers.mainThread()))
            .addConverterFactory(GsonConverterFactory.create(GsonUtil.gson()))
            .client(okHttpClient)
            .baseUrl(host!!)
            .build()
            .create(YourService::class.java)

service.getLotsOfData()
       .flatMapIterable{ it }
       .flatMap{ it.id = id+"whatEverModified" }
       .subscribeOn(Schedulers.io)
       .observeOn(AndroidSchedulers.mainThread())

 interface YourService { @GET("lots/of/data") fun getLotsOfData(): Flowable<CustomModel> }

示例（Java）：

 YourService service = Retrofit.Builder()
            .addConverterFactory(GsonConverterFactory.create(GsonUtil.gson()))
            .client(okHttpClient)
            .baseUrl(host)
            .build()
            .create(YourService.class);

service.getLotsOfData()
       .flatMapIterable(data -> data)
       .flatMap( data -> { data = data +"whatEverModified"; return data; })
       .subscribeOn(Schedulers.io)
       .observeOn(AndroidSchedulers.mainThread());

 interface YourService { @GET("lots/of/data") Flowable<CustomModel> getLotsOfData();  }

这段代码获取您的数据列表，可以通过每个项迭代，将“WhateverModified”附加到模型中的每个id上，并在IO线程中完成所有工作。在修改和获取所有数据之后，它返回主线程中的数据。订阅=处理数据，观察=消耗数据。