Pass vertx-content as additional param to vertx.io Future.fromComplet…

…ionStage
reactiverse · Oct 9, 2023 · ce2c100 · ce2c100
1 parent fe0d02d
commit ce2c100
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/pinot-client/src/main/java/io/reactiverse/pinot/client/impl/VertxConnectionImpl.java b/pinot-client/src/main/java/io/reactiverse/pinot/client/impl/VertxConnectionImpl.java
@@ -44,13 +44,13 @@ public VertxPreparedStatement prepareStatement(String query) {
     @Override
     public Future<ResultSetGroup> execute(String query) {
         var originalFuture = pinotConnection.executeAsync(query);
-        return Future.fromCompletionStage(originalFuture);
+        return Future.fromCompletionStage(originalFuture, vertx.getOrCreateContext());
     }
 
     @Override
     public Future<ResultSetGroup> execute(@Nullable String tableName, String query) {
         var originalFuture = pinotConnection.executeAsync(tableName, query);
-        return Future.fromCompletionStage(originalFuture);
+        return Future.fromCompletionStage(originalFuture, vertx.getOrCreateContext());
     }
 
     @Override

diff --git a/pinot-client/src/main/java/io/reactiverse/pinot/client/impl/VertxPreparedStatementImpl.java b/pinot-client/src/main/java/io/reactiverse/pinot/client/impl/VertxPreparedStatementImpl.java
@@ -37,7 +37,7 @@ public VertxPreparedStatementImpl(Vertx vertx, PreparedStatement preparedStateme
     @Override
     public Future<ResultSetGroup> execute() {
         var originalFuture = preparedStatement.executeAsync();
-        return Future.fromCompletionStage(originalFuture);
+        return Future.fromCompletionStage(originalFuture, vertx.getOrCreateContext());
     }
 
     @Override