Rxjava2源码浅析（三）
首先开始填坑，上篇文章最后的问题还没有解决，subscribeOn是如何切换线程的。先回顾一下： 使用方法： observable.subscribeOn(Schedulers.newThread());我们直接看它重写的abstract方法subscribeActual@Overridepubli...
RxJava2 源码分析
前言很多项目使用流行的Rxjava2 + Retrofit搭建网络框架，Rxjava现在已经发展到Rxjava2，之前一直都只是再用Rxjava，但从来没有了解下Rxjava的内部实现，接下来一步步来分析Rxjava2的源码，Rxjava2分Observable和Flowable两种（无被压和有被压...
RxJava2 源码解析（二）
概述承接上一篇RxJava2 源码解析（一），本系列我们的目的：知道源头(Observable)是如何将数据发送出去的。 知道终点（Observer）是如何接收到数据的。 何时将源头和终点关联起来的 知道线程调度是怎么实现的 知道操作符是怎么实现的本篇计划讲解一下4,5.Rx...
RxJava1升级到RxJava2的注意事项
1、package更改rx1包名由原来的rx.xxx更改为io.reactivex.xxx，并且在同一个module之下，rx1和rx2是不兼容的。2、背压支持RxJava在1.0只有一个个观察者模式，只能部分支持背压：Observable(被观察者)/Observer（观察者）Observable...
ReactiveX 学习笔记（14）使用 RxJava2 + Retrofit2 调用 REST API
JSON:PlaceholderJSON:Placeholder(https://jsonplaceholder.typicode.com/)是一个用于测试的RESTAPI网站。以下使用RxJava2+Retrofit2调用该网站的RESTAPI，获取字符串以及JSON数据。GET/posts/1G...
Android进阶：五、RxJava2源码解析 2
上一篇文章Android进阶：四、RxJava2源码解析1里我们讲到Rxjava2从创建一个事件到事件被观察的过程原理，这篇文章我们讲Rxjava2中链式调用的原理。本文不讲用法，仍然需要读者熟悉Rxjava基本的用法。一.Rxjava2的基本用法Rxjava是解决异步问题的，它的链式调用让代码看起...
Rxjava2实战--第三章 创建操作符
Rxjava2实战--第三章创建操作符Rxjava的创建操作符操作符用途just()将一个或多个对象转换成发射这个或者这些对象的一个Observablefrom()将一个Iterable、一个Future或者一个数组转换成一个Observablecreate()使用一个函数从头创建一个Obervab...
Android进阶：四、RxJava2 源码解析 1
本文适合使用过Rxjava2或者了解Rxjava2的基本用法的同学阅读一.Rxjava是什么Rxjava在GitHub主页上的自我介绍是“alibraryforcomposingasynchronousandevent-basedprogramsusingobservablesequencesfor...
Android RxJava2(四)过滤操作符
Rxjava由于其基于事件流的链式调用、逻辑简洁&使用简单的特点，深受各大Android开发者的欢迎。因此在学习过程中全面的了解了下RxJava的过滤操作符。顾名思义，这类operators主要用于对事件数据的筛选过滤，只返回满足我们条件的数据。filter()ofType()skip()&...
Rxjava2不能再发射Null了
RxJava2的最大改变就是不能再流里发射Null了,有人会问发射了就怎么了,答案是你的流会因为NPE断开.例如下面这段代码因为文件被删了找不到返回null，这时候就不触发下面Consumer的accept。Disposablesubscribe=Observable.fromCallable(ne...