Rxjava 基本操做符

Observable.create(new Observable.OnSubscribe<String>() { @Override public void call(Subscriber<? super String> subscriber) { subscriber.onNext("yang");

>>阅读原文<<