如果在截止日期之前没有生产任何项目，则使用占位符项目完成 Uni，而不取消处理管道

问题描述

我有一个需要很长时间才能完成的异步操作管道，我想 如果管道在截止日期之前没有生成项目，让 Uni 继续使用占位符项目，如下所示：

Uni<Item> u = processingPipeline();
return u.ifNoItem().after(Duration.of(10,SECONDS)).recoverWith(placeholderItem);

但是当使用这个方法时，处理管道被取消并且操作链被中断。 是否可以在截止日期到期时使用占位符项目完成 Uni 而不取消处理管道？即使错过了最后期限，我也希望管道能够持续到最后。 如果有帮助，可以使用 Vert.x。

谢谢

编辑：

这是我迄今为止尝试过的：

Uni<Item> u = processingPipeline();
return Uni.createFrom().emitter(emitter -> {
    vertx.executeBlocking(handler -> {
        u.subscribe().with(emitter::complete);
    },resultHandler -> {});
    vertx.setTimer(TimeUnit.SECONDS.toMillis(10),timerId -> {
        emitter.complete(placeholderItem);
    });
});

当处理在截止日期之前完成时，这可以正常工作，但是如果截止日期到期并且计时器被触发，它会在发出占位符项时与 javax.enterprise.context.ContextNotActiveException 崩溃，并且应用程序似乎陷入困境某种僵局。

编辑 2

事实证明，我的大部分问题实际上都是由于 Hibernate 使用不当造成的。在对 Hibernate 事务的管理方式进行一些重构后，所有随机死锁和其他问题都消失了。

这似乎是原始问题的最优雅的解决方案，即如何在不中断处理的情况下响应一个虚拟项目，除非它在截止日期之前完成：

Uni<Item> u = processingPipeline();
return Uni.createFrom().emitter(emitter -> {
    u.subscribe().with(emitter::complete);
    vertx.setTimer(TimeUnit.SECONDS.toMillis(10),timerId -> {
        emitter.complete(placeholderItem);
    });
});

解决方法

管道的取消是意料之中的，因为 ifNoItem().after(duration) 会触发 TimeoutException。所以这个异常作为失败传播，并且在这个特定点的上游被取消，这符合响应式流语义。

recoverWith 是故障恢复操作符，以及订阅该操作符后的任何内容。

您可能需要查看 recoverWithUni，您可以在其中提供 Uni 作为恢复，而 Uni 将捕获可能重新生成的管道的其余部分 -在这个特定的超时失败点之后订阅。

希望有所帮助。