Tag: reactivex

RxJava和RxAndroid的组合？

我的场景与此图像非常相似： 应用程序的流程将如下所示： 查看需要更新。 使用RxAndroid创建一个observable来从缓存/本地文件中获取数据。 更新视图。 使用Retrofit和RxJava进行另一次网络呼叫，使用来自Web服务的新数据再次更新视图。 使用新数据更新本地文件。 所以，我正在两次更新视图（一个来自本地文件，之后就是通过webservices） 如何使用RxJava和RxAndroid实现结果？ 我在想的是 创建observable1以从本地文件系统获取数据。 在observable1的onNext方法中，我可以创建另一个observable2 。 observable2.onNext()我可以更新本地文件。 现在，我将如何使用更新的数据更新view （加载到文件中）？ 什么是好方法？

使用ReactiveX for Java进行Http调用

我是ReactiveX for Java的新手，我有以下代码块来进行外部http调用，但它不是异步的。 我们使用的是rxjava 1.2和Java 1.8 private ResponseEntity callExternalUrl(String url, String json, HttpMethod method) { RestTemplate restTemplate; HttpEntity request; request = new HttpEntity(jsonContent, httpHeaders); return restTemplate.exchange(url, httpMethod, request, String.class); } 我在网上找到了以下代码块，但我无法理解它以及如何将其应用到我的代码库中。 private RxClient httpClient; public Observable fetchResult(String url, Func1 mapper) { return httpClient.target(url) .request() .rx() .get() .subscribeOn(Schedulers.io()) .map(mapper); }

java rx中Observable.defer和Observable.create之间的区别

有人可以解释我在Observable defer和create方法之间的区别吗？ 我无法理解何时应该使用defer ，何时应该使用create .. 参考文献： 推迟： http ： //reactivex.io/documentation/operators/defer.html 创建： http ： //reactivex.io/documentation/operators/create.html 谢谢