将未来转换为单声道

Question

我有遗留代码，它返回convert java.util.concurrent.Future，现在我应该将此方法调用包装在返回反应堆发布者Mono或Flux的层中。我相信将其转换为任何一种的方法都应该相似，因此将其转换为Mono的正确方法是什么。

例如，假设我从API获取Future，并且需要Mono

Answer 1

您可以在Future::get中使用Mono::fromSupplier作为供应商。像这样Mono.fromSupplier(Future::get)。