rx-java2

0热度

1回答

我有一个简单的工作是使用GreenDao选择数据。另外我想显示ProgressWheel，但是这个作业阻止了UI线程。 showLoader(); DataManager.getInstance(this).getQuestions(0, 800) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedul

0热度

3回答

如何更改Observable.interval的周期，以及如何在运行时停止并恢复Observable ticks

有没有办法在运行时更改Observable.interval周期？有没有办法停止和恢复Observable.interval滴答？有没有办法重置间隔时间？其实我用下面的代码做了一段时间为永远的动作，但我有在运行时间上没有控制，我不得不停止，恢复，休息，并在运行时改变期。 Observable.interval(8, TimeUnit.SECONDS).observeOn(AndroidSch

0热度

2回答

正确的方式来重复发射事件流的操作

我是RxJava的新手，所以我仍然试图让自己的头靠近它。我有一个Observable代表一串按钮点击，所以它很热。每次点击该按钮时，我都想做一些I/O。如果失败，我想重复并尝试再次执行该I/O，直到成功。这似乎是一个使用retry()或repeat()的好机会，但那些只能用于热门的可观察对象，而不是冷的。下面是一些伪代码来获得在我想要做的事： buttonRequests .map(a

0热度

1回答

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

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

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

如何根据一组值更新数据模型

该方案是基于整数值的Set更新列表中的数据模型。例如有一个ArrayList： Student { name: "abc", id: 1, hasPassed: false }... 现在我有一个整数集，基本上在其内部具有学生ID {1，2，...}通过学生表示学生证。我得到Student arrayList onNext我的observer方法。如何根

0热度

1回答

DisposableCompletableObserver泄漏即使我正在清除CompositeDisposable

我是RxJava和LeakCanary的新手，因此这可能是简单的事情（希望）。基本上我有一个活动，其中包括一个CompositeDisposable。我得到了我的Singleton存储库的实例，并使用它来获取Completable，并将其添加到CompositeDisposable。在onPause中，我清除了CompositeDisposable，这让我相信会避免调用对象（在本例中为Acti

2热度

1回答

用Dagger 2和RxJava2包装SharedPreferences

我是否需要包装Android SharedPreferences类？如果是的话，你能否给我一个简单的工作例子？我知道如何使用SharedPreferences，但是当涉及到包装它并为它提供Dagger 2和RxJava2时，我很困惑。

1热度

2回答

RxJava1到Rxjava2迁移错误

转换RxJava1代码RXJava2给予这个错误，不知道我做错了无类型变量（一个或多个）R的实例（S）存在，使得单>符合ObserableSource API调用 @GET("/search/users?per_page=2") Observable<UsersList> searchGithubUsers(@Query("q") String searchTerm); @GET("htt

1热度

2回答

Android RxJava2应用程序在创建observable时调用emitter.onError（）时崩溃

我在create()的帮助下手动创建Observable。现在里面，我检查一些条件&基于此，我想通知用户有关错误。以下是我正在创建观察到： public Observable<User> loginUser(String email, String password) { return Observable.create( emitter -> { myAsync