RxJava2一次流程源码分析总结

//一次调用 Disposable disposable = Observable .create(new ObservableOnSubscribe<Integer>() { @Override public void subscribe(ObservableEmitter<Integer> e) throws Exception

>>阅读原文<<