自定义实现Rxjava 借助实现简单的Rxjava理解源码:Obserable/Observer、操作符、线程切换 已实现部分: CustomObserverable.create() CustomObservable.map() CustomObservable.flatmap() CustomObservable.zip() CustomObservable.subscribeOn() CustomObservable.observeOn()