Flux 不输出任何结果

Question

开始学习javareactor 3.下面的代码无法输出任何结果

  Flux.create(sink -> {
           
            sink.next("produce a number： " + Math.random() * 100);
            // sink.complete();
        }).publishOn(Schedulers.elastic())
                .subscribe(
                      consumer -> System.out.println(Thread.currentThread().getName() + consumer),
                        error -> System.out.println("error！" + error),
                        () -> {
                            System.out.println("task complete！");
                        });

Answer 1

您必须阻止 main()，直到用户输入 System.in.read();。就在这之后subscribe()！您的应用程序在执行之前退出的问题发生在 Flux.

Flux 不输出任何结果

Flux Don't output any result

java

reactor