如何从 Vert.x Future 创建 Observable？答案

【问题标题】：How to create a Observable from a Vert.x Future?如何从 Vert.x Future 创建 Observable？
【发布时间】：2017-09-26 13:48:47
【问题描述】：

我有一个 io.vertx.core.Future 的实例，因为我需要将多个处理程序设置到同一个 Future 中，根据这个问题 https://github.com/eclipse/vert.x/issues/1920 的方法是使用 Observables。

但我没有找到从 Future 获取 Observable 的方法。

我尝试了rx.Observable.from( Future )，但它不起作用，因为它不是 Java Future。

我查看了RxHelper 并没有将 Future 作为参数的toObservable 方法。

我错过了什么？任何帮助表示赞赏。

【问题讨论】：

标签： vert.x rx-groovy

【解决方案1】：

您可以创建一个ObservableFuture 并将其处理程序用作原始Future 的处理程序

import io.vertx.core.Future
import io.vertx.rx.java.RxHelper

def myFuture = Future.<String> future()

def obsFut = RxHelper.observableFuture()
myFuture.setHandler(obsFut.toHandler())

obsFut.subscribe({ s ->
  println "Hello $s"
})

myFuture.complete("John")

打印

Hello John

【讨论】：