如何有条件地执行Reactor的单通量/通量供应商操作？

Question

如何有条件地执行

我有一个返回Mono的方法

有人能帮我找到合适的供应商运营商吗？

    public static void main(String[] args) {
        Mono.just("GOOD_SIGNAL")//It can also be a BAD_SIGNAL
                .flatMap(s -> firstMethod(s))
                .then(secondMethod())
                .subscribe()
        ;
    }

    private static Mono<String> secondMethod() {
        //This method call is only valid when the firstMethod is success
        return Mono.just("SOME_SIGNAL");
    }

    private static Mono<Void> firstMethod(String s) {
        if ("BAD_SIGNAL".equals(s)) {
            Mono.error(new Exception("Some Error occurred"));
        }

        return Mono
                .empty()//Just to illustrate that this function return Mono<Void>
                .then();
    }

-谢谢

Answer 1

首先，我想强调的是，Reactor的Mono/通量（下一步将考虑Mono）有以下调节操作符（至少我知道）：

• 单声道#开关IFempty
• Mono#defaultIfEmpty
• 将Mono#filter和一些其他供应商操作符（例如，Mono#flatMap）组合在一起

第二点是单声道，然后：

忽略此单声道中的元素，并将其完成信号转换为所提供单声道的发射和完成信号。错误信号将在生成的单声道中重放。

因此，这意味着无论之前的值是什么，都将返回该值（空的或提供的）。

考虑到所有这些因素，您的解决方案应该是这样的：

public static void main(String[] args) {
        Mono.just("GOOD_SIGNAL")//It can also be a BAD_SIGNAL
                .flatMap(s -> firstMethod(s))
                .switchIfEmpty(secondMethod())
                .doOnError(...)//handle you error here
                .subscribe();
    }

private static Mono<String> secondMethod() {
     //This method call is only valid when the firstMethod is success
     return Mono.just("SOME_SIGNAL");
}

private static Mono<Void> firstMethod(String str) {
    return Mono.just(str)
               .filter(s -> "BAD_SIGNAL".equals(s))
               .map(s -> new Exception("Some Error occurred: "+s))
               .flatMap(Mono::error);
}

Answer 2

则在其源代码中传播错误，因此它涵盖了这方面。据我了解，您不能使用平面地图而不是则的原因是源代码为空，这是由于firstMethod（）。在这种情况下，将deer（）和然后（）结合起来以实现您所寻求的懒惰：

Mono.just("GOOD_SIGNAL")//It can also be a BAD_SIGNAL
    .flatMap(s -> firstMethod(s))
    .then(Mono.defer(this::secondMethod))
    .subscribe();