草庐IT

rxjs_observable

全部标签

java - RxJava 2.0 中的 Observable 和 Flowable 有什么区别?

Observable和Flowable接口(interface)似乎是相同的。为什么在RxJava2.0中引入了Flowable?什么时候我应该更喜欢使用Flowable而不是Observable? 最佳答案 如thedocumentation中所述:AsmallregretaboutintroducingbackpressureinRxJava0.xisthatinsteadofhavingaseparatebasereactiveclass,theObservableitselfwasretrofitted.Themainiss

java - RxJava 2.0 中的 Observable 和 Flowable 有什么区别?

Observable和Flowable接口(interface)似乎是相同的。为什么在RxJava2.0中引入了Flowable?什么时候我应该更喜欢使用Flowable而不是Observable? 最佳答案 如thedocumentation中所述:AsmallregretaboutintroducingbackpressureinRxJava0.xisthatinsteadofhavingaseparatebasereactiveclass,theObservableitselfwasretrofitted.Themainiss

java - 使用 RxJava 链两个改造 observables

我想一个接一个地执行2个网络调用。两个网络调用都返回Observable。第二次调用使用第一次调用的成功结果中的数据,第二次调用成功结果中的方法使用第一次和第二次调用的both成功结果中的数据。我也应该能够以不同的方式处理bothonError“事件”。我怎样才能避免回调hell,如下例所示:API().auth(email,password).subscribeOn(Schedulers.newThread()).observeOn(AndroidSchedulers.mainThread()).subscribe(newAction1(){@Overridepublicvoidca

java - 使用 RxJava 链两个改造 observables

我想一个接一个地执行2个网络调用。两个网络调用都返回Observable。第二次调用使用第一次调用的成功结果中的数据,第二次调用成功结果中的方法使用第一次和第二次调用的both成功结果中的数据。我也应该能够以不同的方式处理bothonError“事件”。我怎样才能避免回调hell,如下例所示:API().auth(email,password).subscribeOn(Schedulers.newThread()).observeOn(AndroidSchedulers.mainThread()).subscribe(newAction1(){@Overridepublicvoidca

java - 在 Android 中使用 Observable

我想实现一个NavigationView,其中包含许多完全依赖于MainActivity中定义的值的fragment。我知道MainActivity中的变量可以使用MainActivity中定义的方法从其他Fragment访问以获取值,但这里要注意的是MainActivity中变量的值可能改变(在AsyncThread上运行)。现在,我要么更改代码,以便我的fragment根据fragment本身中的某些事件更新它们的值,要么使用SharedPreference。但我不想使用SharedPreferences,也不需要多次检查值的变化。我知道在RxJS中,我们使用异步运行的Observ

java - 在 Android 中使用 Observable

我想实现一个NavigationView,其中包含许多完全依赖于MainActivity中定义的值的fragment。我知道MainActivity中的变量可以使用MainActivity中定义的方法从其他Fragment访问以获取值,但这里要注意的是MainActivity中变量的值可能改变(在AsyncThread上运行)。现在,我要么更改代码,以便我的fragment根据fragment本身中的某些事件更新它们的值,要么使用SharedPreference。但我不想使用SharedPreferences,也不需要多次检查值的变化。我知道在RxJS中,我们使用异步运行的Observ

java - java.util.Observable 是否在任何地方使用?

正在与一位同事谈论Java库的设计。我提到我一直觉得很有趣的是,在UI小部件上本质上提供Observable接口(interface)的AWT/Swing类实际上被称为“监听器”。随后他指出与java.util.Observer会发生名称冲突,这让我大吃一惊。和java.util.Observable,自JDK1.0以来一直存在。我以前从未听说过它们。JavaDocs和google/googlecode中没有列出任何用法没有想出太多,所以有人知道它们是否在JDK中的某个地方使用过吗?他们似乎没有收到任何普通的爱,所以大概他们不“受欢迎”。有人发现它们有用吗?

java - java.util.Observable 是否在任何地方使用?

正在与一位同事谈论Java库的设计。我提到我一直觉得很有趣的是,在UI小部件上本质上提供Observable接口(interface)的AWT/Swing类实际上被称为“监听器”。随后他指出与java.util.Observer会发生名称冲突,这让我大吃一惊。和java.util.Observable,自JDK1.0以来一直存在。我以前从未听说过它们。JavaDocs和google/googlecode中没有列出任何用法没有想出太多,所以有人知道它们是否在JDK中的某个地方使用过吗?他们似乎没有收到任何普通的爱,所以大概他们不“受欢迎”。有人发现它们有用吗?

java - 如何停止和恢复 Observable.interval 发出滴答声

这将每5秒发出一次滴答声。Observable.interval(5,TimeUnit.SECONDS,Schedulers.io()).subscribe(tick->Log.d(TAG,"tick="+tick));要阻止它,您可以使用Schedulers.shutdown();但是随后所有的调度程序都停止了,以后不可能恢复滴答作响。如何“优雅地”停止和恢复发射? 最佳答案 这是一种可能的解决方案:classTickHandler{privateAtomicLonglastTick=newAtomicLong(0L);priva

java - 如何停止和恢复 Observable.interval 发出滴答声

这将每5秒发出一次滴答声。Observable.interval(5,TimeUnit.SECONDS,Schedulers.io()).subscribe(tick->Log.d(TAG,"tick="+tick));要阻止它,您可以使用Schedulers.shutdown();但是随后所有的调度程序都停止了,以后不可能恢复滴答作响。如何“优雅地”停止和恢复发射? 最佳答案 这是一种可能的解决方案:classTickHandler{privateAtomicLonglastTick=newAtomicLong(0L);priva