无法触发信号停止块在项目Reactor

Question

我想在Project Retor中尝试block可选。根据描述，它用于

订阅此单声道并无限期地阻止，直到收到下一个信号或单声道完成空

我尝试了以下方法。

Mono<Void> triggerSignal() {
    Signal.next("signal");
}

triggerSignal()
    .delayElement(Duration.ofSeconds(30))
    .blockOptional();

System.out.println("Outside chain");

我希望看到“外链”在30年代延迟之前打印出来。然而，我必须等待30多岁。

没有收到信号吗？当收到信号时，程序块应该停止？这是发送信号的正确方式吗？

Answer 1

< code>triggerSignal()确实会立即产生信号。

但是，链中的下一项是delayElement（）调用，它将始终延迟30发出的元素（在它到达反应式链中的下一个运算符之前）；因此block可选（）在30秒过去之前永远不会“看到”信号。

这听起来像是你想，相反，在你等待信号时阻止长达30秒。如果是这种情况，则可以将持续时间传递给 blockOptional（） 而不是延迟元素，例如：

triggerSignal()
    .blockOptional(Duration.ofSeconds(30));