complete requestObserver even if there is no progressIndicator

JetBrains · Feb 6, 2024 · e666127 · e666127
1 parent 00e439c
commit e666127
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/vectoriadb-java-client/src/main/java/jetbrains/vectoriadb/client/VectoriaDBClient.java b/vectoriadb-java-client/src/main/java/jetbrains/vectoriadb/client/VectoriaDBClient.java
@@ -202,7 +202,10 @@ public void onCompleted() {
             progressIndicator.accept(-1, -1);
             requestObserver.onCompleted();
             progressIndicator.accept(Integer.MAX_VALUE, Integer.MAX_VALUE);
+        } else {
+            requestObserver.onCompleted();
         }
+
         try {
             finishedLatch.await();
         } catch (InterruptedException e) {