jjzjj

RxAndroid

全部标签

android - RxJava- 动态 EditText 上的 RxAndroid 表单验证

我的表格可以有可变数量的EditText需要在提交表单之前进行验证。如果EditText,我可以执行验证检查s的数量是固定的,如下所示-ObservableemailObservable=RxTextView.textChanges(editEmail).skip(1);ObservablepasswordObservable=RxTextView.textChanges(editPassword).skip(1);mFormValidationSubscription=Observable.combineLatest(emailObservable,passwordObservabl

android - 如何使用 RxJava/RxAndroid 从 Android 服务更新 UI

我有一个负责下载文件的绑定(bind)服务,因此它知道下载状态/进度。UI(fragment或Activity)必须显示/更新服务的下载进度。实际上,我认为常见的方法是使用BroadcastReciever或来自Activity的CallBack。但我在某处听说过使用RxJava(ReactiveX编程)和mediator类(以及将其注入(inject)服务和Activity的Dagger),如下所述。所以我的问题是如何用这些东西处理RxJava?任何代码示例?除了使用Intent之外,还有其他有效的方法吗?资源:MoreefficientwayofupdatingUIfromServ

android - 如何使用 RxAndroid 压缩 Kotlin 语言中的一些 observables

我有一些问题。我是RxJava/RxKotlin/RxAndroid的初学者,不了解某些功能。例如:importrus.pifpaf.client.data.catalog.models.Categoryimportrus.pifpaf.client.data.main.MainRepositoryimportrus.pifpaf.client.data.main.models.FrontDataModelimportrus.pifpaf.client.data.product.models.Productimportrx.Observableimportrx.Singleimport

android - 如何使用 RxAndroid 压缩 Kotlin 语言中的一些 observables

我有一些问题。我是RxJava/RxKotlin/RxAndroid的初学者,不了解某些功能。例如:importrus.pifpaf.client.data.catalog.models.Categoryimportrus.pifpaf.client.data.main.MainRepositoryimportrus.pifpaf.client.data.main.models.FrontDataModelimportrus.pifpaf.client.data.product.models.Productimportrx.Observableimportrx.Singleimport

java - RxAndroid 和 Retrofit : Unable to create call adapter for io. reactivex.Observable<retrofit2.Response<okhttp3.ResponseBody>>

我正在尝试使用rxJava、rxAndroid、Retrofit2和OkHTTP3从URL端点下载文件。我的代码无法为“Observable>”创建调用适配器。这些方法对我来说是新的,所以我相信我在这里遗漏了一个重要的概念。非常感谢任何方向或观点。FATALEXCEPTION:mainProcess:com.example.khe11e.rxdownloadfile,PID:14130java.lang.IllegalArgumentException:Unabletocreatecalladapterforio.reactivex.Observable>formethodRetrof

java - 在 RxJava/RxAndroid 中为 Activity 生命周期处理订阅的正确方法是什么?

我刚刚开始使用RxJava/RxAndroid。我想避免上下文泄漏,所以我像这样创建了一个BaseFragment:publicabstractclassBaseFragmentextendsFragment{protectedCompositeSubscriptioncompositeSubscription=newCompositeSubscription();@OverridepublicvoidonDestroy(){super.onDestroy();compositeSubscription.unsubscribe();}}在我扩展BaseFragment的fragment

android - 将 AsyncTask 转换为 RxAndroid

我有以下方法使用otto和AsyncTask向UI发布响应。privatestaticvoidonGetLatestStoryCollectionSuccess(finalStoryCollectionstoryCollection,finalBusbus){newAsyncTask(){@OverrideprotectedVoiddoInBackground(Void...params){bus.post(newLatestStoryCollectionResponse(storyCollection));returnnull;}}.execute();}我需要帮助才能使用RxAnd

java - Rxandroid SubscribeOn 和 ObserveOn 有什么区别

我只是在学习Rx-java和Rxandroid2,我只是很困惑SubscribeOn和ObserveOn之间的主要区别是什么。 最佳答案 SubscribeOn指定Observable将在其上运行的调度程序。ObserveOn指定观察者将在其上观察此Observable的调度程序。所以基本上,SubscribeOn主要在后台线程上订阅(执行)(您不想在等待可观察对象时阻塞UI线程),并且在ObserveOn中您想在主线程上观察结果...如果您熟悉AsyncTask,那么SubscribeOn类似于doInBackground方法和O

Android 异步操作库 RxJava

RxJava概述RxJava是一种响应式编程,来创建基于事件的异步操作库。基于事件流的链式调用、逻辑清晰简洁。RxJava我的理解是将事件从起点(上游)流向终点(下游),中间有很多卡片对数据进操作并传递,每个卡片获取上一个卡片传递下来的结果然后对事件进行处理然后将结果传递给下一个卡片,这样事件就从起点通过卡片一次次传递直到流向终点。RxJava观察者模式传统观察者是一个被观察者多过观察者,当被观察者发生改变时候及时通知所有观察者RXjava是一个观察者多个被观察者,被观察者像链条一样串起来,数据在被观察者之间朝着一个方向传递,直到传递给观察者。RxJava原理理解:被观察者通过订阅将事件按顺序

Android 异步操作库 RxJava

RxJava概述RxJava是一种响应式编程,来创建基于事件的异步操作库。基于事件流的链式调用、逻辑清晰简洁。RxJava我的理解是将事件从起点(上游)流向终点(下游),中间有很多卡片对数据进操作并传递,每个卡片获取上一个卡片传递下来的结果然后对事件进行处理然后将结果传递给下一个卡片,这样事件就从起点通过卡片一次次传递直到流向终点。RxJava观察者模式传统观察者是一个被观察者多过观察者,当被观察者发生改变时候及时通知所有观察者RXjava是一个观察者多个被观察者,被观察者像链条一样串起来,数据在被观察者之间朝着一个方向传递,直到传递给观察者。RxJava原理理解:被观察者通过订阅将事件按顺序