本文共 1788 字，大约阅读时间需要 5 分钟。

目的

了解 onNext、onComplete、doOnNext、doFinally、doAfterTerminate执行的执行顺序。

测试代码

import io.reactivex.Observable;import org.junit.Test;/** * @description: 测试onNext、onComplete、doOnNext、doFinally、doAfterTerminate执行顺序 * @author: lizz * @date: 2020/11/17 17:56 */public class ExeOrder {    @Test    public void orderTester() {        Observable.just("Hello Tester1")                .doOnNext(s -> System.out.println("doOnNext：" + s))                .doFinally(() -> System.out.println("doFinally1"))                .doAfterTerminate(() -> System.out.println("doAfterTerminate1"))                .doFinally(() -> System.out.println("doFinally2"))                .doAfterTerminate(() -> System.out.println("doAfterTerminate2"))                .subscribe(                        s -> System.out.println("onNext：" + s),                        throwable -> System.out.println("onError" + throwable),                        () -> System.out.println("onComplete"));        System.out.println("*******调整顺序**********");        //调整顺序        Observable.just("Hello Tester2")                .doAfterTerminate(() -> System.out.println("doAfterTerminate1"))                .doFinally(() -> System.out.println("doFinally1"))                .doOnNext(s -> System.out.println("doOnNext：" + s))                .doAfterTerminate(() -> System.out.println("doAfterTerminate2"))                .doFinally(() -> System.out.println("doFinally2"))                .subscribe(                        s -> System.out.println("onNext：" + s),                        throwable -> System.out.println("onError" + throwable),                        () -> System.out.println("onComplete"));    }}

执行结果

结果分析

• 优先级doOnNext>onNext>onComplete>doFinally/doAfterTerminate
• doFinally和doAfterTerminate执行顺序不固定，由onComplete方法执行完成后向上游依次执行，离得"近"的优先执行。

转载地址：https://lizz6.blog.csdn.net/article/details/109749106 如侵犯您的版权，请留言回复原文章的地址，我们会给您删除此文章，给您带来不便请您谅解！