Rxjava2从入门到源码（二）
一、本期要点 写博客就应该和鞋小说一样，时常更新，那今天主要讲的是 rxjava 的另一部分内容，线程切换，之前的文章讲的是一些基础的用法，那今天就讲一下 rxjava 中的另一个强大的功能，线程切换，当我们需要在 rxjava 中执行耗时代码的时候，线程切换就很重要了，...
#RxJava2源码解析（2）
上一篇中，我们对最基本的使用方法进行了源码分析，可是这远远不能体现rxJava的强大，我们没有看到线程转换，没有看到强大的操作符，还记得我们想通过分析RxJava2源码所达到的目的么？有5个。 我们的目的： 知道源头(Observable)是如何将数据发送出去的。 知道终点（Observ...
Rxjava2之rxandroid基本用法
rxAndroid的github地址https://github.com/ReactiveX/RxAndroid 配置:module下 compile 'io.reactivex.rxjava2:rxandroid:2.0.1'compile 'io.reactivex.rxjava2:rxja...
Rxjava2源码浅析（三）
首先开始填坑，上篇文章最后的问题还没有解决，subscribeOn是如何切换线程的。先回顾一下： 使用方法： observable.subscribeOn(Schedulers.newThread());我们直接看它重写的abstract方法subscribeActual@Overridepubli...
RxJava2 源码解析（二）
概述承接上一篇RxJava2 源码解析（一），本系列我们的目的：知道源头(Observable)是如何将数据发送出去的。 知道终点（Observer）是如何接收到数据的。 何时将源头和终点关联起来的 知道线程调度是怎么实现的 知道操作符是怎么实现的本篇计划讲解一下4,5.Rx...
Android拾萃 - RxJava2之变换操作符及其demo
Android拾萃 - RxJava2操作符汇总 Android拾萃 - RxJava2之创建操作符及其demo 一、变换操作符列表 操作符 解析 buffer() 缓存，可以简单的理解为缓存，它定期从Observable收集数据到一个集合，然后把这些...
[Android开发] RxJava2之路一 - 观察者模式
一、 简介是本人学习RxJava的经验总结，因为RxJava是基于这个模式的，所以我们先学习这个观察者模式，是完全必要的。会了这个模式再看RxJava就简单很多了。二、啥是观察者模式？观察者模式(Observer)模式： 是对象的行为模式，又叫做 - 发布-订阅(Publish/Subscribe)...
Rxjava2的学习与总结
Rxjava2基础认知 形式正确的有限Observable 调用观察者的onCompleted正好一次或者它的onError正好一次，而且此后不能再调用观察者的任何其它方法。如果onComplete 或者 onError 走任何一个 都会 主动解除订阅关系； 如果解除订阅关系以后在发射 onEr...
RxJava2 / RxAndroid2的merge操作合并多个Observable
RxJava2/RxAndroid2的merge操作合并多个Observable RxAndroid2/RxJava2的merge操作合并若干个Observable为单个可观测的Observable，形成单一线性的Observable输出结果，例如代码： package zhangphil.app;...
[Android开发] RxJava2之路八 - 辅助操作符例子Demo
一、辅助操作符列表 用于处理Observable的操作符，例如延迟、定时等。 名称 解析 materialize() 将Observable转换成一个通知列表 dematerialize() 将上面的结果逆转回一个Observable timesta...
基于Rxjava2的事件总线：Rxbus
以前的项目中使用的是EventBus来实现事件的通知和订阅，RxJava2发布之后就使用了新的方式：RxBus，减少添加的依赖库。如果有什么错误的地方，或者有更好的建议的欢迎大家在下边留言，互相学习。 没有背压处理（Backpressure）的 RxBus import android.su...
Android RxJava2(四)过滤操作符
Rxjava由于其基于事件流的链式调用、逻辑简洁 & 使用简单的特点，深受各大 Android开发者的欢迎。因此在学习过程中全面的了解了下RxJava的过滤操作符。顾名思义，这类operators主要用于对事件数据的筛选过滤，只返回满足我们条件的数据。 ...
[置顶] RxJava2 源码解析（二）
转载请标明出处： http://blog.csdn.net/zxt0601/article/details/61637439 本文出自:【张旭童的博客】(http://blog.csdn.net/zxt0601) 概述承接上一篇RxJava2 源码解析（一）， 本系列我们的目的： 知...
RxJava2用Observable.fromIterable时可以设置线程调度吗？
我用Observable.fromIterable遍例一个集合时，担心集合太大比较耗时，所以用了以下代码： Observable.fromIterable(xxxList) .Schedulers.newThread()) .observeOn(AndroidSchedulers.mai...
[Android开发] RxJava2之路二 - 基本使用方法
一、啥是RXJava1.1 简介一个在Java Jvm上使用可观测的序列来组成异步的、基于事件的程序的库。 概念很复杂，没所谓。我们先学会使用。RxJava github地址： https://github.com/ReactiveX/RxJava RxJava github地址： https://...
[Android开发] RxJava2之路七 - 错误处理操作符例子Demo
一、错误处理操作符列表用于对Observable发射的 onError 通知做出响应或者从错误中恢复，例如，你 可以： 吞掉这个错误，切换到一个备用的Observable继续发射数据 吞掉这个错误然后发射默认值 吞掉这个错误并立即尝试重启这个Observable 吞掉这个错误，在一些回...
[Android开发] RxJava2之路九 - 条件操作符例子Demo
一、条件操作符列表 根据条件发射或变换Observables 名称 解析 amb() 给定多个Observable，只让第一个发射数据的Observable发射全部数据 defaultIfEmpty() 发射来自原始Observable的数据，如果原始Ob...
Rxjava2之rxandroid基本用法
rxAndroid的github地址https://github.com/ReactiveX/RxAndroid 配置:module下 compile 'io.reactivex.rxjava2:rxandroid:2.0.1'compile 'io.reactivex.rxjava2:rxja...
2、RxJava2 & Retrofit2 封装实践 初始化
RxJava2&Retrofit2的基本实现 RxJava2 & Retrofit2 & Rxlifecycle 依赖 compile 'com.squareup.okhttp3:okhttp:3.7.0' compile 'com.squa...
关于RxJava2和retrofit2使用的问题
在retrofit2配合使用rxjava时候，出现了如下问题： java.lang.IllegalArgumentException: Unable to create call adapter for io.reactivex.Observable<com.price.take_ne...