如何在没有阻塞的情况下，在空单声道之后链接反应式操作？

Question

基本上，我试图实现的是调用第二个存储库（一个ReactiveCrudRepository）或抛出一个异常，这取决于调用第一个存储库的结果。

我最初的想法是这样的：

java prettyprint-override">/** Reactive with blocking code */
public Flux<SecondThing> getThings(String firstThingName) {
    FirstThing firstThing = firstRepo
        .findByName(firstThingName)
        // Warning: "Inappropriate blocking method call"
        .blockOptional()  // this fails in test-context
        .orElseThrow(() -> new FirstThingNotFound(firstThingName));

    return secondRepo.findAllByFirstThingId(firstThing.getId());
}

这将对应于以下非反应性方法：

/** Non-reactive */
public List<SecondThing> getThings(String firstThingName) {
    FirstThing firstThing = firstRepo
        .findByName(firstThingName)
        .orElseThrow(() -> new FirstThingNotFound(firstThingName));

    return secondRepo.findAllByFirstThingId(firstThing.getId());
}

我还没有找到一种方法来以反应性非阻塞的方式做到这一点。所有我需要的是抛出一个错误，如果一个空的Mono出来的第一个调用，并继续管道，如果不是空的；但我似乎不能使用onErrorStop或doOnError在这里正确，和map没有帮助，因为它跳过了空的Mono。

如果我使用id而不是name，我有一个解决办法，但我不太满意它，因为它在第一件事的实例没有链接到它的情况下显示了不同的行为：

/** Reactive workaround 1 */
public Flux<SecondThing> getThings(Long firstThingId) {
    return secondRepo
        .findAllByFirstThingId(firstThingId)
        .switchIfEmpty(
            Flux.error(() -> new FirstThingNotFound(firstThingName))
        );
}

我发现的另一个解决方案是以下内容，它将空的Mono替换为null值，但它看起来不正确，并且也会引发警告：

/** Reactive workaround 2 */
public Flux<SecondThing> getThings(String firstThingName) {
    return firstRepo
        .findByName(firstThingName)
        // Warning: "Passing 'null' argument to parameter annotated as @NotNull"
        .defaultIfEmpty(null)
        .flatMapMany(
            firstThing -> secondRepo.findAllByFirstThingId(firstThing.getId()
        )
        .onErrorMap(
            NullPointerException.class, e -> new FirstThingNotFound(firstThingName)
        );
}

什么是正确的方法来链对两个存储库的调用，以便与请求的firstThingName一起存在或不存在FirstThing条件调用到第二回购？

Answer 1

我找到了一个如此简单的解决方案，以至于我为没有更早地找到它而感到羞愧：

public Flux<SecondThing> getThings(String firstThingName) {
    return firstRepo
        .findByName(firstThingName)
        .switchIfEmpty(Mono.error(() -> new FirstThingNotFound(firstThingName)))
        .flatMapMany(
            firstThing -> secondRepo.findAllByFirstThingId(firstThing.getId()
        );
}

诀窍在于switchiffempty不会强制您选择“有效”的替换值，因此可以使用Mono。错误直接传播正确的异常。