如何在Flux上同时调用订阅和阻止？

Question

我一直在试验项目反应器和反应流。我在使用订阅On使流在不同的线程上运行时遇到了一个问题。将我的代码放在主线程中，我需要主线程块，直到流完成，所以我做了这样的事情：

        Flux.just(1, 2, 3, 4)
                .log()
                .subscribeOn(Schedulers.parallel())
                .subscribe((i) -> {
                   // some operation 
                });

        try {
            Thread.sleep(20000L);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        System.out.println("Finished");

然后我注意到有一个块最后（）方法执行阻塞。但是我不能同时使用订阅和块最后，因为它们不返回Flux。

有什么优雅的方法可以做到这一点吗？

Answer 1

所有块方法都代表您进行订阅。您可以将原本放在订阅lambda中的代码移动到等效的doOn*方法中