rx-java

-1热度

1回答

我正试图执行一个抛出异常的函数。 Observable.fromCallable { foo() } .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .take(1) .onErrorReturn { /* onError operation *

1热度

2回答

RxJava：如何预先startWith（）默认发射EVERY TIME父亲observable发射？

即时通讯试图有一个模式，在这里我观察到其产生的一些对象，转化成域事件，如开始，成功，周围观察到的产emited错误，如果是有道理的 public Observable<BookRenderingEvent> extractAndRenderObservable(String epubPath) { return extractObservable(epubPath) .

1热度

2回答

BlockingGet块UI线程RxJava 2

我正在处理这个问题。我试图打电话RxJava在同步方式，但是这样做的结果阻断主线程。这里是我的代码 @Override public Single<SettingsBundle> getSettings() { SettingsBundle settingsModel = mSettingsManager.getSettings(); return Singl

0热度

1回答

代码适用于RX Completable not blocked onSubscribe thread

我有一些传统的非RX代码，通过产生一个新的Thread来完成一些网络工作。工作完成后，它会在回调中调用一个方法。我无法控制此代码运行的线程。这是遗产，它自己产生了一个新的Thread。 interface Callback { void onSuccess(); } static void executeRequest(String name, Callback callbac

2热度

1回答

有没有办法重构这个RxJava代码？

我有我的订阅可观察看起来像： compositeDisposables.add(githubService.getRepos() .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribe( (List<Github

0热度

1回答

如何对两个可观察对象使用自定义合并函数

我有两个观察对象发出相同的数据类型。我需要把它们合并 Single<Post.List> postsRecent = getRecentPosts() .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()); Single<Post.List> postsPopular

0热度

1回答

Rx：强制可观察至少需要N秒才能完成

我正在为我的应用制作启动画面。我希望它在进入主屏幕前至少持续N秒。我有一个Rx变量myObservable从服务器或从我的本地缓存中返回数据。我如何强制myObservable在中完成至少N秒？ myObservable // .doStuff to make it last at least N seconds .subscribe(...)

0热度

1回答

RxJava：循环中的异步调用

我有一个整数列表和每个整数，我想从数据库中获取一个字符串值，并将其放入一个Map中，其中整数是来自父列表的整型值，并且字符串是从数据库中获取的字符串值。我也想要获取并行运行的字符串。这是我用RxJava实现的。我的代码工作，我得到了预期的结果，但我不认为提取名称并行运行。 public Observable<Map<Integer, String>> getVitalsForConnectedD

0热度

2回答

RxJava单/接口

的可观回报的实现我还面临着有趣的问题我有以下方法 @Override public Single<IResults> getResults() { return Single.just(new ConcreteResults()); } IResults是一个接口，ConcreteResults是落实。但是我得到一个错误 Error:(149, 27) error: inco

0热度

3回答

http post response is null

我发送http post请求给REST API，我从服务器获得状态ok响应，但是在这个脚本中，它总是运行'myError'函数。在后端，一切运行良好，没有任何错误。在错误函数中，响应值仍未定义。 var toDoApp = angular.module('toDoApp'); toDoApp.factory('registrationService', function() { var re