RxJava操作符实践：11_转换操作之2_toFuture 发表于 2016-10-23 | 分类于 RxJava | 一、描述这个操作符将Observable转换为一个返回单个数据项的Future。 阅读全文 »
RxJava操作符实践：11_转换操作之1_getIterator 发表于 2016-10-21 | 分类于 RxJava | 一、描述这个操作符将Observable转换为一个Iterator，你可以通过它迭代原始Observable发射的数据集。 阅读全文 »
RxJava操作符实践：10_连接操作之4_refCount 发表于 2016-10-21 | 分类于 RxJava | 一、描述让一个可连接的Observable行为像普通的Observable。 阅读全文 »
RxJava操作符实践：10_连接操作之3_replay 发表于 2016-10-21 | 分类于 RxJava | 一、描述保证所有的观察者收到相同的数据序列，即使它们在Observable开始发射数据之后才订阅。 阅读全文 »
RxJava操作符实践：10_连接操作之2_publish 发表于 2016-10-20 | 分类于 RxJava | 一、描述将普通的Observable转换为可连接的Observable。 阅读全文 »
RxJava操作符实践：9_反压操作之3_onBackpressureLatest 发表于 2016-10-19 | 分类于 RxJava | 一、描述当Observable发出的元素的速度比订阅者消化得要快,订阅者会接收Observable最新发出的item进行处理。 阅读全文 »
RxJava操作符实践：9_反压操作之2_onBackpressureDrop 发表于 2016-10-19 | 分类于 RxJava | 一、描述如果消费者无法处理数据，则 onBackpressureDrop 就把该数据丢弃了。 阅读全文 »
RxJava操作符实践：9_反压操作之1_onBackpressureBuffer 发表于 2016-10-19 | 分类于 RxJava | 一、描述onBackpressureBuffer 会缓存所有当前无法消费的数据，直到 Observer 可以处理为止。 阅读全文 »
RxJava操作符实践：8_算术和聚合操作之7_reduce 发表于 2016-10-19 | 分类于 RxJava | 一、描述按顺序对Observable发射的每项数据应用一个函数并发射最终的值。 阅读全文 »