do操作符用的相对比较少，就好比do...while循环和while循环，前者相对后者来说使用次数较少。
do操作符基本代码如下：
Observable.create(new ObservableOnSubscribe<String>() {
@Override
public void subscribe(ObservableEmitter<String> emitter) {
emitter.onNext("hello word A");
emitter.onNext("hello word B");
emitter.onNext("hello word C");
//emitter.onError(new Throwable("this is nullpointException"));
emitter.onComplete();
}
}).doOnSubscribe(new Consumer<Disposable>() {
@Override
public void accept(Disposable disposable) throws Exception {
System.out.println("doOnSubscribe -- 观察者和被观察者连接时被调用");
}
}).doOnNext(new Consumer<String>() {
@Override
public void accept(String s) throws Exception {
System.out.println("doOnNext -- "+s);
}
}).doAfterNext(new Consumer<String>() {
@Override
public void accept(String s) throws Exception {
System.out.println("doAfterNext -- "+s);
}
}).doOnDispose(new Action() {
@Override
public void run() throws Exception {
System.out.println("doOnDispose -- ");
}
}).doAfterTerminate(new Action() {
@Override
public void run() throws Exception {
System.out.println("doAfterTerminate -- ");
}
}).doFinally(new Action() {
@Override
public void run() throws Exception {
System.out.println("doFinally -- ");
}
}).doOnComplete(new Action() {
@Override
public void run() throws Exception {
System.out.println("doOnComplete -- ");
}
}).doOnError(new Consumer<Throwable>() {
@Override
public void accept(Throwable throwable) throws Exception {
System.out.println("doOnError -- ");
}
}).doOnLifecycle(new Consumer<Disposable>() {
@Override
public void accept(Disposable disposable) throws Exception {
System.out.println("doOnLifecycle1 -- ");
}
}, new Action() {
@Override
public void run() throws Exception {
System.out.println("doOnLifecycle2 -- ");
}
}).doOnEach(new Consumer<Notification<String>>() {
@Override
public void accept(Notification<String> stringNotification) throws Exception {
System.out.println("doOnEach -- "+stringNotification.getValue());
}
}).subscribe();
执行效果如下：
图片.png
基本说明
（1）doOnSubscribe：在被观察者和观察者产生关联的时候被调用，disposable可以立即取消订阅；
（2）doOnLifecycle：可以在订阅之后设置是否取消订阅；
（3）doNext和doAfterNext：可以接收到被观察者发射过来的数据；
（4）doOnEach：当onNext、onError、onComplete被触发是被调用；
（5）doOnComplete：当触发onComplete时被调用；
（6）doOnError：当触发onError时被调用；
（7）doFinally：当触发onError或onComplete时被调用；
（8）doOnDispose：当取消订阅时被调用；
（9）doAfterTerminate：订阅终止时被调用；
