初学Reactor一个奇怪的问题

Question

1. 初学在学习Reactor的过程中，一个奇怪的问题

第一个doOnNext窥视流打印出了内容，第二个doOnNext就没有打印出任何东西求解

StepVerifier.create(
        Flux.just("flux", "mono")
                .flatMap(s -> Flux.fromArray(s.split("\\s*"))   // 1
                        .delayElements(Duration.ofMillis(100))) // 2
                .doOnNext(System.out::print)) // 3
                .expectNextCount(8) // 4
                .verifyComplete();
        // fmlounox
        System.out.println();
        Flux.just("flux", "mono")
                .flatMap(s -> Flux.fromArray(s.split("\\s*"))
                        .delayElements(Duration.ofMillis(100)))
                .doOnNext(System.out::print);
        // 什么也没输出

所用Reactor版本：

        <dependency>
            <groupId>io.projectreactor</groupId>
            <artifactId>reactor-core</artifactId>
            <version>3.2.8.RELEASE</version>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>io.projectreactor</groupId>
            <artifactId>reactor-test</artifactId>
            <version>3.2.8.RELEASE</version>
            <scope>test</scope>
        </dependency>

Answer 1

响应式数据流在被订阅之前，声明的操作不会被执行

第一个被StepVerifier.create调用后被订阅了，而第二个没有被订阅。

可以调用subscribe方法来手动订阅它

        Flux.just("flux", "mono")
                .flatMap(s -> Flux.fromArray(s.split("\\s*"))
                        .delayElements(Duration.ofMillis(100)))
                .doOnNext(System.out::print).subscribe();

由于delayElements添加了延迟，直接放在main方法内的话你可能还需要在后面添加一个Thread.sleep(800)才能看到完整的输出。

        Flux.just("flux", "mono")
                .flatMap(s -> Flux.fromArray(s.split("\\s*"))
                        .delayElements(Duration.ofMillis(100)))
                .doOnNext(System.out::print).subscribe();
        Thread.sleep(800);