rx-android

0热度

1回答

如果我做这样的事情： Observable.just(1) .flatMap( //inner chain Observable.just(2) .subscribeOn(Schedulers.newThread()) ) .map(// we are in the inner chain thread! //) .subscribeOn(Schedulers

0热度

1回答

使用RxAndroid进行翻新时出现重复文件异常

我想用RxAndroid进行翻新，因此我导入了如下所示的所需依赖项。但WHN我运行应用程序时，我收到以下错误： Error:Execution failed for task ':app:transformResourcesWithMergeJavaResForDebug'. > com.android.build.api.transform.TransformException: com.a

0热度

1回答

发布到特定的观察员使用PublishSubject

我有ViewPager两页，即热门和全部。我试图实现的只是推动项目，有热门标签真正到热门而所有项目推到全部。目前我有一个类用于PagerAdapter并传递页面类型。如何过滤掉PublishSubject，以便每个页面只显示相应的必需项目。我的观察者都订阅了单个PublishSubject，但是我想要在发射时过滤我的。如果问题不清楚，请发表评论。我会尽我所能来传达这个问题。如果因为找不到任

1热度

1回答

截断所有表格 - 房间

什么是截断房间库中所有表格的最快方式？我的目标是使用一个RxJava清除整个数据库CompletableFromAction。是否有可能创建从多个表中删除的@ Query？

0热度

3回答

哪个库我应该使用RxAndroid和RxJava

我想使用RxAndroid和RxJava，但我有点困惑哪些下面提到的库我应该使用？在一些教程它们使用例如以下类其可在 compile 'io.reactivex:rxandroid:1.2.1' compile 'io.reactivex:rxjava:1.1.9' .subscribe(new Subscriber<String>) 和一些教程哎使用例如它们使用下列类，其是可以在以下

0热度

2回答

用RxAndroidBle编写多个特征的正确方法是什么？

我是Rx的新手，仍在努力弄清楚如何正确处理观察对象。我想知道是否有更好的方法来编写多个特性，而不是使用RxAndroidBle一次完成一个特性？目前，我一次只做一个，代码如下。 Observable<RxBleConnection> mConnectionObservable; private void saveChanges(String serialNumber, Date date, M

0热度

1回答

RxJava 2 - 如何链接异步电话

我刚刚开始学习RxJava，所以如果我要求一个新手问题，请不要将它钉死在十字架上，但我已经花了好几天的时间来尝试解决这个问题，但没有取得任何成功。我已经阅读了几乎所有我能找到的文档，并沿着大多数关于http://reactivex.io/tutorials.html的教程进行了跟踪。我搜索了StackOverflow和互联网的其他高低，但显然我似乎是这个星球上唯一有这个问题的人。这很奇怪，因为它基

0热度

1回答

在SplashActivity中处理多个TCP和HTTP响应

我应该在SplashActivity中组织2个HTTP（Retrofit + Rx）和2个TCP（KryoNet）请求。当我从所有请求得到响应时，我应该启动MainActivity。如何组合请求，处理响应，然后开始MainActivity？亲爱的开发者，请帮助我。我目前正与琥珀金协议（https://github.com/kyuupichan/electrumx/blob/master/docs

1热度

1回答

Observable仍然在UI线程上运行

我遇到了在新线程上运行RxJava observables的问题。我试图在Scheduler.io()上运行压缩的DB查询，但它无论如何都会阻塞UI线程。不知道为什么。代码为DB： public Observable<List<T>> searchModelsInView(View view, final Collection<String> searchTerms, KeyMatc

1热度

1回答

使用配置的观察者不重新订阅源

我试图通过创建一个单一的实例DisposableSingleObserver/DisposableObserver并通过它通过subscribeWith()方法在像下面的流上重复使用观察者的单一和Observable流： public class SomeClass { private DisposableSingleObserver<Object> observer; pu