onNext如果您
Observable不发出任何声音,则无需致电。您可以使用
Void签名来做类似的事情
Observable<Void> o = Observable.create(new Observable.OnSubscribe<Void>() { @Override public void call(Subscriber<? super Void> subscriber) { // Do the work and call onCompleted when you done, // no need to call onNext if you have nothing to emit subscriber.onCompleted(); }});o.subscribe(new OnCompletedObserver<Void>() { @Override public void onCompleted() { System.out.println("onCompleted"); } @Override public void onError(Throwable e) { System.out.println("onError " + e.getMessage()); }});您可以定义一个OnCompletedObserver来简化您的Observer回调,这样您就不必覆盖onNext,因为您不需要它。
public abstract class OnCompletedObserver<T> implements Observer<T> { @Override public void onNext(T o) { }}如果我了解您的要求,那么就可以解决问题。



