RxJava2.0(三)谈一谈基础功能源码实现

前言 咱们在使用RxJava的时候最经常使用的功能就是写一个被观察者、一个观察者。在被观察者中发射数据，在观察者中接收数据，最后用subscribe将二者给订阅起来实现最基础的功能。例以下面这种：git //被观察者 Observable<String> observable = Observable.create(new ObservableOnSubscribe<String>

>>阅读原文<<