如何在空 Mono 之后链接反应操作而不阻塞？

Question

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

我最初的想法是这样的：

/** 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，我有一个解决方法，但我对它不太满意，因为它在FirstThing 的实例但没有@ 的情况下表现出不同的行为987654332@链接到它：

/** 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)
        );
}

将调用链接到两个存储库的正确方法是什么，以便FirstThing 与请求的firstThingName 的存在或不存在决定对第二个存储库的调用？

Answer 1

我找到了一个如此简单的解决方案，以至于我可能会为没有早点找到它而感到羞耻：

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

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