如何将回调转换为promise

Question

我正在使用play框架和Apache Kafka。

我有一个POST方法，它向Kafka发送消息。Kafka有一个API方法

公共java.util.concurrent。未来发送（生产记录记录、回调）

其中Javadoc说

异步发送记录到主题，并在发送被确认时调用提供的回调。

我将使用play框架公开此功能。我想返回一个＜代码＞promise

Answer 1

经过一番搜索，在这本书的帮助下找到了答案。

以下是代码

RedeemablePromise<Result> promise = RedeemablePromise.empty();

kafkaProducer.send(record, (metadata, ex) -> {
    if (ex != null) {
        promise.failure(ex);
    } else {
        promise.success(created(Json.toJson(new ProduceResult())));
    }
});