在开发软件的时候，我们需要确保代码正确执行。为了快速的获取每次修改后的反馈，通常开发人员使用自定义测试。在同步的 Rx 中测试和普通 Java 中的单元测试没有太大的区别。如果要测试异步代码，可能会有点需要注意的地方，比如要测试下面的代码：Observable.interval(1, TimeUnit.SECONDS)
.take(5)上面的 Observable 发射一个数据流，需要 5秒...
分类：
编程语言 时间：
2016-07-10 18:56:20
阅读次数：
211
Rx 尽量避免状态泄露到数据流之外的场景。但是有些东西本身就带有状态。比如服务器可以上线和离线、手机可以访问Wifi、按钮被按下了等。在 Rx 中国，我们在一段时间内看到这些事件，并称之为窗口（window）。其他事件在这个窗口内发生可能需要特殊处理。例如，手机在使用移动收费上网的时候，会把网络请求优先级降低，来避免天价流量费的情况。
注意：上面的一段话估计是翻译的，有点语句不通。更多参考官网：...
分类：
编程语言 时间：
2016-07-10 18:56:13
阅读次数：
318
BackpressureRx 中的数据流是从一个地方发射到另外一个地方。每个地方处理数据的速度是不一样的。如果生产者发射数据的速度比消费者处理的快会出现什么情况？在同步操作中，这不是个问题，例如：// Produce
Observable producer = Observable.create(o -> {
o.onNext(1);
o.onNext(2);...
分类：
编程语言 时间：
2016-07-10 18:42:52
阅读次数：
400
任务我们有个 Web API，获取指定标签的所有新闻列表,每条新闻包含时间和内容等。
我们的任务就是下载新闻列表,选择最新的新闻,然后保存在本地。假设第三方提供的jar里面提供了Api和ApiImpl,不可再更改:
假设getNewsList耗时1.5秒，save耗时0.5秒
1.接口：public interface Api { //同步方式
List getNew...
分类：
编程语言 时间：
2016-07-07 06:22:40
阅读次数：
477
Create 使用一个函数从头创建一个Observable
Just 将一个或多个对象转换成发射这个或这些对象的一个Observable
From 将一个Iterable 一个Future 或者一个数组转换成一个Observable
Defer 只有当订阅者订阅才创建Observable为每个订阅创建一个新的Observable
Timer 创建一个在给定的延...
分类：
编程语言 时间：
2016-07-06 15:16:10
阅读次数：
594
转载请标明出处：
http://blog.csdn.net/xmxkf/article/details/51791120
本文出自:【openXu的博客】目录：使用示例
subscribeOn原理
多次subscribeOn的情况
observeOn原理
调度器的种类
各种操作符的默认调度器
源码下载??RxJava中 使用observeOn和subscribeOn操作符，你可以让Obser...
分类：
编程语言 时间：
2016-07-05 01:09:55
阅读次数：
742
前言 我从去年开始使用 RxJava ，到现在一年多了。今年加入了 Flipboard 后，看到 Flipboard 的 Android 项目也在使用 RxJava ，并且使用的场景越来越多 。而最近这几个月，我也发现国内越来越多的人开始提及 RxJava 。有人说『RxJava 真是太好用了』，有 ...
分类：
移动开发 时间：
2016-07-04 13:34:02
阅读次数：
309
线程控制Scheduler二
1Scheduler的API二
2Scheduler的原理二
1 subscribeOn
这边是版本110的源码
这边是版本116的源码 建议看这个
2 observeOn1.线程控制Scheduler(二)给 Android 开发者的 RxJava 详解1）Scheduler的API（二）前面讲到了，可以利用 subscribeOn()结合 observeOn()...
分类：
编程语言 时间：
2016-07-03 19:58:19
阅读次数：
273
对rxJava不了解的同学可以先看 RxJava 和 RxAndroid 一 (基础)RxJava 和 RxAndroid 二（操作符的使用）RxJava 和 RxAndroid 三（生命周期控制和内存优化） RxJava 和 RxAndroid 四（RxBinding的使用） 本文将有几个例子说明 ...
分类：
移动开发 时间：
2016-06-29 18:51:45
阅读次数：
336
基本定义
Observable – 被观察者（事件源）
Observer – 观察者
Creating Observables（创建操作）以下展示了创建Observable的各种方法Create — 通过observer的方法创建一个新的Observable
Defer — 直到observer订阅的时候才会创建这个Observable，并且为每一个observer创建一个Observable
Em...
分类：
编程语言 时间：
2016-06-29 11:25:07
阅读次数：
1496
