Project Reactor 的 or() 运算符使用问题

Question

我想链接Monos 并发出第一个非空的。我认为 or() 运算符就是为此目的而设计的。

这是我的Monos 链：第一个是空的，第二个应该发出“hello”。

@Test
void orTest() {
    Mono<String> chain = Mono.<String>empty().or(Mono.just("hello"));

    StepVerifier.create(
        chain
    )
        .expectNext("hello")
        .verifyComplete();
}

但是，我得到以下失败：

java.lang.AssertionError: expectation "expectNext(hello)" failed (expected: onNext(hello); actual: onComplete())

有人可以帮忙吗？我在这里做错了什么？

Answer 1

您误解了or() - 它需要来自任一发布者的first result emitted。这与发出的第一个 item 非常不同 - 如果其中一个 Mono 对象发出 onComplete() 结果而不返回任何内容，那么，就像您的情况一样，您将获得该结果没有发出任何东西。

如果您改为执行 Mono.<String>empty().delaySubscription(Duration.ofMillis(100)).or(Mono.just("hello")); 之类的操作，您可以看到此行为，这几乎肯定会通过（因为 emtpy Mono 的 onComplete() 结果被延迟到足以让另一个 Mono 先发出项目.)

但是，您使用的方法是 switchIfEmpty()，它（顾名思义）将等待第一个 Mono 完成，然后如果第一个返回空结果，则回退到第二个：

@Test
public void orTest() {
    Mono<String> chain = Mono.<String>empty().switchIfEmpty(Mono.just("hello"));

    StepVerifier.create(chain)
            .expectNext("hello")
            .verifyComplete();
}