rxjava2源码分析阅读

首先来一手最简单的调用。 Observable .create(new ObservableOnSubscribe<File[]>() { @Override public void subscribe(ObservableEmitter<File[]> emitter) throws Exception {

>>阅读原文<<