rx-android

0热度

1回答

所以我有一个异步操作A取决于第二个，B。如何使B成为A的延续，就像您在.NET TPL中使用then函数的函数或ContinueWith一样？让我们从Android上scenarion在那里我有两个服务端点：一个用于提取网址的图像一个用于读取图像本身代码： private void loadImage(final ImageView imageView) { Observable

0热度

1回答

如何使用可观察与flatMap

我以下列方式使用rxjava维护任务的定时器发出的结果：在一类，我需要定期维护，我用下面的静态订阅，这导致可观测当班级被加载到内存中时，首次启动，然后按照指定的时间间隔进行。 private static Subscription subscription = Observable.timer(0, 5, TimeUnit.SECONDS) .flatMap(new Func1<Lo

0热度

1回答

如何防止队列计时器迭代中的Observable

我正在使用以下Observable执行常规任务。 Observable在类首次加载到内存中时启动，然后定期执行我的代码。由于它是一个单一的Observable，它可以保证[从我的测试看，假设代码从不第二次启动，并且在运行时间比间隔长的情况下并行处理。 private static Subscription subscription = Observable.timer(0, 1000, TimeU

2热度

1回答

RxAndroid：同步执行一个可观察的

我从Rx开始使用RxAndroid，我想通过它的API来使用Retrofit列出GitHub用户的名称。每个API请求都会带来100个用户，在我处理了所有想要获得下一个100个用户的用户之后，我不知道该怎么做。任何人都可以帮助我？哪里是我的代码的更新接口 interface GitHubService { @GET("/users") List<User> users(@Q

6热度

1回答

Android + RxJava - 从数据库和网络服务加载数据

我想使用RxJava从Web服务（通过改造）加载数据。我也有一个以前的结果数据库缓存。让我们假设我已经有可观的每一项： Observable<List<MyModel>> networkObservable = retrofitService.getModels(); Observable<List<MyModel>> dbObservable = database.getModels();