@Test public void executeBlockingShouldCompleteSingle() throws InterruptedException { CountDownLatch countDownLatch = new CountDownLatch(1); queryExecutor.executeBlocking(h -> { }) .subscribe(v -> countDownLatch.countDown()); countDownLatch.await(1, TimeUnit.SECONDS); }
public static <T> Single<T> executeBlocking(Handler<Promise<T>> blockingCodeHandler, Vertx vertx) { return vertx.rxExecuteBlocking(blockingCodeHandler,false).toSingle(); }
RXTool { public static <T> Single<T> executeBlocking(Handler<Promise<T>> blockingCodeHandler, Vertx vertx) { return vertx.rxExecuteBlocking(blockingCodeHandler,false).toSingle(); } }
RXTool { public static <T> Single<T> executeBlocking(Handler<Promise<T>> blockingCodeHandler, Vertx vertx) { return vertx.rxExecuteBlocking(blockingCodeHandler,false).toSingle(); } private  RXTool(); }
RXTool { public static <T> Single<T> executeBlocking(Handler<Promise<T>> blockingCodeHandler, Vertx vertx) { return vertx.rxExecuteBlocking(blockingCodeHandler,false).toSingle(); } private  RXTool(); static Single<T> executeBlocking(Handler<Promise<T>> blockingCodeHandler, Vertx
        vertx); static Observable<T> executeBlockingObservable(Handler<Promise<List<T>>> blockingCodeHandler, Vertx
        vertx); static Single<T> failure(Throwable e); }
RXTool { public static <T> Single<T> executeBlocking(Handler<Promise<T>> blockingCodeHandler, Vertx vertx) { return vertx.rxExecuteBlocking(blockingCodeHandler,false).toSingle(); } private  RXTool(); static Single<T> executeBlocking(Handler<Promise<T>> blockingCodeHandler, Vertx
        vertx); static Observable<T> executeBlockingObservable(Handler<Promise<List<T>>> blockingCodeHandler, Vertx
        vertx); static Single<T> failure(Throwable e);  }