Filter 只发射通过了谓词测试的数据项
OfType ofType是filter操作符的一个特殊形式它过滤一个Observable只返回指定类型的数据
Take 只发射开始的N项数据
TakeLast 只发射最后N个元素
TakeLastBuffer 将最后的N项数据当做单个数据发射
Skip 跳过开始的N项数据
SkipLast 跳过后面...
分类：
编程语言 时间：
2016-07-13 16:52:31
阅读次数：
2500
在开发软件的时候，我们需要确保代码正确执行。为了快速的获取每次修改后的反馈，通常开发人员使用自定义测试。在同步的 Rx 中测试和普通 Java 中的单元测试没有太大的区别。如果要测试异步代码，可能会有点需要注意的地方，比如要测试下面的代码：Observable.interval(1, TimeUnit.SECONDS)
.take(5)上面的 Observable 发射一个数据流，需要 5秒...
分类：
编程语言 时间：
2016-07-10 18:56:20
阅读次数：
211
BackpressureRx 中的数据流是从一个地方发射到另外一个地方。每个地方处理数据的速度是不一样的。如果生产者发射数据的速度比消费者处理的快会出现什么情况？在同步操作中，这不是个问题，例如：// Produce
Observable producer = Observable.create(o -> {
o.onNext(1);
o.onNext(2);...
分类：
编程语言 时间：
2016-07-10 18:42:52
阅读次数：
400
Create 使用一个函数从头创建一个Observable
Just 将一个或多个对象转换成发射这个或这些对象的一个Observable
From 将一个Iterable 一个Future 或者一个数组转换成一个Observable
Defer 只有当订阅者订阅才创建Observable为每个订阅创建一个新的Observable
Timer 创建一个在给定的延...
分类：
编程语言 时间：
2016-07-06 15:16:10
阅读次数：
594
欢迎讨论与交流 : ） 注 代码参考自——汇智网 RxJS教程 前言 Observable观察者模式令小白笔者眼前一亮。数据生产者(observable)负责生产新鲜的数据，同时在生产完毕后'通知“消费者”：“hey！哥们，货已经准备好了，你可以过来拿啦！” 代码 ...
分类：
Web程序 时间：
2016-07-05 01:04:12
阅读次数：
466
基本定义
Observable – 被观察者（事件源）
Observer – 观察者
Creating Observables（创建操作）以下展示了创建Observable的各种方法Create — 通过observer的方法创建一个新的Observable
Defer — 直到observer订阅的时候才会创建这个Observable，并且为每一个observer创建一个Observable
Em...
分类：
编程语言 时间：
2016-06-29 11:25:07
阅读次数：
1496
概述从concatMap操作我们知道，concat操作符肯定也是有序的，而concat操作符是接收若干个Observables，发射数据是有序的，不会交叉。使用示例示例一下面使用concat操作符 来实现个多数据源的例子，比如一个商品详情需要展示商品的信息、艺术家信息、与该商品类似的商品，可能需要访问三个接口。这个时候就可以使用concat操作符。卖家信息private Observable<Obj...
分类：
编程语言 时间：
2016-06-21 06:54:16
阅读次数：
239
业务需求当我们在app里发起网络请求时，可能会因为各种问题导致失败。如何利用RxJava来实现出现错误后重试若干次，并且可以设定重试的时间间隔。具体实现网络请求使用Retrofit来做，请求用户信息接口@GET("/userinfo?noToken=1")
Observable getUserInfoNoToken();请求用户信息接口的逻辑代码...
分类：
编程语言 时间：
2016-06-21 06:53:24
阅读次数：
211
concatMap 作用concatMap操作符和flatMap操作符非常类似。下面是concatMap操作符的流程图：concatMap和flatMap最大的区别是concatMap发射的数据集是有序的，flatMap发射的数据集是无序的。如下代码：Observable.from(Arrays.asList(
"http://www.baidu.com/",...
分类：
编程语言 时间：
2016-06-21 06:51:48
阅读次数：
732
概述
Returns an Observable that emits the results of a specified combiner function applied to combinations of two items emitted,
in sequence, by two other Observables.
流程图： 简单来说zip操作符就是合并多个数据流，...
分类：
移动开发 时间：
2016-06-21 06:49:26
阅读次数：
170
