quarkus @观测台invoke调用Uni

Question

在异步观察者中调用Uni的最佳方法是什么？如果我能返回Uni，那就太好了，但不幸的是，这是行不通的。

void observe(@ObservesAsync MyEvent event) {
    Uni<Object> task;
}

Answer 1

正如@ladicek所提到的，你可以：

termination

• use

1. 使用同步观测器并阻塞，直到使用火和遗忘方法
2. “触发”异步操作为止(虽然它不是严格的异步，但它只是在另一个线程上运行)并生成一个。

1)同步观测器并阻塞直到终止

void observe(@Observes MyEvent event) {
    Uni<Void> uni = ...;
    uni.await().indefinitely();

}

2)同步观测器，并使用火忘方法触发异步操作。

void observe(@Observes MyEvent event) {
    Uni<Void> uni = ...;
    uni.subscribeAsCompletionStage(); // Fire and forget, no error reporting

}

或者：

void observe(@Observes MyEvent event) {
    Uni<Void> uni = ...;
    uni.subscribe().with(success -> ..., failure -> log(failure));
}

创建一个CompletionStage 异步观测器并生成

void observe(@Observes MyEvent event) {
    Uni<Void> uni = ...;
    return uni.subscribeAsCompletionStage();
}