RxJava2一次流程源碼分析總結

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

>>阅读原文<<