RxJava - JVM的Reactive Extensions - 一个库，用于使用Java VM的可观察序列组合异步和基于事件的程序。
我的问题将是更多的设计或架构相关。只需要更有经验的工程师的建议。我现在正在学习RxJava / RxAndroid，并想在...中替换我的异步逻辑
我需要测试像这样的东西Observable.just（1）.delay（20，SECONDS）对于测试，我使用了trampoline调度器Observable.just（1）.delay（20，SECONDS，schedulers.getComputation（））并进行测试。 ..
我正在尝试转换此AsyncTask：私有静态类UpdateFeedTask扩展AsyncTask {private WeakReference weakFeedFragment;私人的 ...
我有一个Android应用程序，可以从SQLite数据库中添加和删除。我想知道以下的最佳做法。向表中添加新行时，可能会出现两种不同的方式。 1）......
rxjava使用Single在doOnSuccess中传递参数
Java 8 io.reactivex：rxjava：1.3.6 kotlin 1.2.21我试图使用Single传递doOnSuccess中的参数。但是，我收到一个错误，我似乎无法解决。上课...
我的应用程序的一个要求是允许用户进行多个步骤，然后在完成时根据每个步骤中的条目将值写入数据库。用户界面中的每一步都可能......
我有像这样的java代码mDataManager.getObservable（“hello”）。subscribe（subscriber）;我想验证以下Observable是.subscribe（）我试图模拟...
我在我的应用程序中使用Firebase以及RxJava。 Firebase能够在后端数据中发生更改（添加，删除，更改等）时通知您的应用。我想把...结合起来
我正在使用Retrofit2 + RxJava + RxAndroid进行网络呼叫。我尝试了不同的调度程序，同样io（）和newThread（）。我知道使用newThread（）的后果，但仍然...
帮助编写多个网络调用并在Rxjava中累积结果。 （我在Android应用程序中使用。）状态 - 列表 cityList; City - cityId; RestCall 1可观察
RxJava相对较新。有以下要求。任何指针都会有所帮助。例如： - 有3个可观察量A，B，C，这样A从数据源发出数据，如DB B＆C，都取决于......的数据
我在just（）运算符中传递两个参数。我的代码片段是：Observable observable = Observable.just（1,2）; observable.subscribeOn（Schedulers.newThread（））...
Android Studio 3.1 RC 2 kotlin 1.2.30 fetchMessage Single的签名 fetchMessage（final String messageId）;我试图转换为Java的kotlin代码。但是，我...
具有state的Observable.generator，其中新状态是异步更新的
这是一个有点人为的例子，但请耐心等待。假设我有一个方法，例如：Single getValue（int offset）;我想多次打电话给这个，传递一个不同的......
我正在开发一种汽车牌游戏，它允许你创建一个帐户并拥有一些汽车卡。基本上，服务器上的每个新创建的帐户都已拥有一些卡。在下面的代码中，我...
我面临以下问题：我有一个生成和Observable的查询。 fun onQueryTextChange（newText：String？）：Boolean {val disposable = model .search（newText）。 ...
使用Jake Wharton的管理状态和RxJava模式。我将两个api调用组合在一起并行执行。两者完成后如何发出“成功”项目？请参阅 ...
我有一个自定义对象列表（列表 itemsList）。这是我的自定义类：public class Item {private String itemId; private String itemName;初始列表只有......
我使用下面的代码：mCompositeDisposable.add（myObservable（IdLang，shortTermCoursesModels）.subscribeOn（Schedulers.io（））。observeOn（AndroidSchedulers.mainThread（））...
onNext（）onError（）回调没有在第二个订阅android上执行
我有一个像这样的Observable：@GET（“endpoint”）可观察 取得一些东西（）;和订阅者一样，这个订阅者 somethingSubscriber =新订阅者