rx-java2

-1热度

1回答

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

0热度

2回答

如何为Recyclerview的每个项目分别请求？

我有一个RecyclerView和它所代表的数据列表。我从包含唯一标识的服务器/数据库中获取数据，基于这个项目标识我想向服务器/数据库发出请求，并且想要在RecyclerView上显示它。我正在提出一个单独的请求，我想请求尽可能多的项目，因为它在屏幕上可见。我已经定义了10个项目，我从服务器接收并显示他们，但对于每一个项目，我需要更多的细节做额外的请求，并显示在同一个屏幕在onBindVie

1热度

1回答

防抖动单位无视超时测试

我有这样的方法来从API public void fetchSearchResults(Observable<String> searchObservable) { searchObservable .filter(search -> !TextUtils.isEmpty(search)) .debounce(700, TimeUnit.MILLISECONDS)

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回答

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

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

0热度

2回答

RxJava单/接口

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

0热度

1回答

RxAndroid - 使用Zip操作符处理错误

我试图找到一种并行执行请求的方法，并在每个observable完成时处理它们。尽管所有的观察对象都给出了回应，但所有事情都能正常工作，但在完成所有事情时我没有办法处理所有的错误。这是拉链运算符，它基本上并行地执行2名的请求的示例： Observable.zip( getObservable1() .onErrorResumeNext { errorThrowab

1热度

1回答

RxJava2将两个Flowables合并为一个

我很努力地找到任何将两个Flowable合并成一个的RxJava2实例。我想修改包括沿 Integer[] ints = new Integer[count]; Integer[] moreints = new Integer[count]; Arrays.fill(ints, 777); Arrays.fill(moreints, 777); Fl

0热度

2回答

如何使用RxJava获得来自Realm的物品列表的Observable？

我只有这个： public Observable<List<Movie>> getAll() { return Observable.just(Movie.class) .flatMap(t -> Observable.just(t) .doOnSubscribe(disposable -> realm.executeTransaction(realm1