Mono.error(OutOfMemoryError)p 处理不一致

Question

我试图了解如果您订阅带有几个变体的 Mono.error(new OutOfMemoryError("hello world")) 会发生什么。

我通过了这些测试（使用 reactor-core 3.4.3）：

    @Test
    public void oom() {
        Mono.error(new OutOfMemoryError("hello world")).subscribe();
    }

    @Test
    public void oom_thenReturn() {
        try {
            Mono.error(new OutOfMemoryError("hello world")).thenReturn(123).subscribe();
            fail("Expected OOMError");
        } catch (OutOfMemoryError e) {
            // expected
        }
    }

    @Test
    public void oom_then_thenReturn() {
        Mono.error(new OutOfMemoryError("hello world")).then().thenReturn(123).subscribe();
    }

    @Test
    public void genericError_thenReturn() {
        Mono.error(new Error("hello world")).thenReturn(123).subscribe();
    }

因此，如果您订阅Mono.error(new OutOfMemoryError("hello world")).thenReturn(123)，它会在订阅线程上引发异常。但是如果你省略了thenReturn(123) 调用，在它之前添加一个额外的then() 调用，或者使用通用的Error 而不是OutOfMemoryError，订阅线程上不会抛出异常。 （如果您添加日志记录 Subscriber，您会看到 onSubscribe 和 onError 被按预期调用。）

我知道为什么OutOfMemoryError 会与Error 受到不同的处理，但我不明白为什么thenReturn(123) 调用会导致错误传播到订阅线程，而并非如此。谁能解释一下？

Answer 1

OutOfMemoryError 在 Reactor 中被视为不可恢复的异常。它可能会抛出它而不是把它变成一个合适的onError 信号。

项目反应堆reference:

然而，Reactor 定义了一组异常（例如 OutOfMemoryError) 总是被认为是致命的。见 Exceptions.throwIfFatal 方法。这些错误意味着 Reactor 无法 继续运行并被抛出而不是传播。