import io.vertx.reactivex.core.Future; //导入依赖的package包/类
public static void retrievePrice(WebClient pricer, Map.Entry<String, Object> entry, Future<JsonObject> future) {
    pricer.post("/prices")
        .rxSendJson(new JsonObject()
            .put("name", entry.getKey())
            .put("quantity", entry.getValue())
        ).subscribe(
        resp -> future.complete(resp.bodyAsJsonObject()),
        future::fail
    );
}
 

import io.vertx.reactivex.core.Future; //导入依赖的package包/类
/**
 * Utility method to report the completion/failure from a Single to a Future.
 *
 * @param future the future
 * @return the single observer to pass to {@link Single#subscribe()}
 */
public static SingleObserver<JsonObject> toObserver(Future<JsonObject> future) {
    return new SingleObserver<JsonObject>() {
        public void onSubscribe(@NonNull Disposable d) {
        }

        public void onSuccess(@NonNull JsonObject item) {
            future.tryComplete(item);
        }

        public void onError(Throwable error) {
            future.tryFail(error);
        }
    };
}
 

import io.vertx.reactivex.core.Future; //导入依赖的package包/类
public static <T> Single<T> executeBlocking(Handler<Future<T>> blockingCodeHandler, Vertx
    vertx) {
    return vertx.rxExecuteBlocking(blockingCodeHandler);
}
 

import io.vertx.reactivex.core.Future; //导入依赖的package包/类
public static <T> Observable<T> executeBlockingObservable(Handler<Future<List<T>>> blockingCodeHandler, Vertx
    vertx) {
    return executeBlocking(blockingCodeHandler,vertx)
        .flatMapObservable(Observable::fromIterable);
}
 

import io.vertx.reactivex.core.Future; //导入依赖的package包/类
public MeshResponse(io.vertx.core.Future<T> delegate) {
	super(delegate);
}
 

import io.vertx.reactivex.core.Future; //导入依赖的package包/类
public static <T> MeshResponse<T> create() {
	return new MeshResponse<T>(io.vertx.core.Future.future());
}
 

import io.vertx.reactivex.core.Future; //导入依赖的package包/类
public static <T> Observable<T> executeBlockingObservable(Handler<Future<List<T>>> blockingCodeHandler, Vertx
    vertx) {
    return executeBlocking(blockingCodeHandler,vertx)
            .flatMapObservable(Observable::fromIterable);
}