Reactor3-如何在单核错误时返回通量？

Question

这是样板代码：我想做这样的事情-

public Flux<Object2> getSomething(String email) {
    method1(email).map(result -> {  //method1 returns Mono<Object1>
        if(result.id().isEmpty()) {
            return method2(email); //method2 returns Flux<Object2>
        } else {
            return Flux.empty();
        }
    };
});

因此，当method1返回空的Object1时。id（），则只调用method2。否则返回空流量。

需要注意的指针是-

>

没有到达第二个方法调用

因为一个方法是Mono，另一个是Flux，所以如果我直接在第2行中添加返回，就会出现类型不匹配。

我尝试了方法1：

if(Object1.id().isEmpty()){

   throw new IllegalArgumentException;
}

在上面的代码片段中：

try {
    method1(email);
} catch(IllegalArgumentException e) {
    return method2(email);
}

这里从不例外。

Answer 1

应该使用switchIfEmpty（）运算符。

另外，如果您想从方法返回两种类型（Mono和Flux），那么将返回类型更改为org。反应流。出版商不过，我不推荐这样做。

而不是返回通量。即使只有1个数据要返回，也可以作为流量返回。将Mono转换为Flux，如果为空，则用户切换IfEmpty操作符以发送不同的Flux流。

Answer 2

您的第一个代码片段不应该编译，因为方法实现没有重新调整任何内容，所以我将尝试猜测发生了什么。

这里不会发生任何事情，因为方法没有返回您正在创建的发布服务器。如果没有任何东西订阅该通量/单声道，则不会发生任何事情。

public Flux<Object2> getSomething(String email) {
    return method1(email)
              .filter(result -> result.id().isEmpty())
              .flatMapMany(result -> method2(email));
}

然后，您可以使用filter过滤掉结果，如果谓词不满足，则不从该Mono发出任何内容。此外，flatMap很多将帮助您在这里将结果转换为理论收益类型。