Start progress printer thread before all feeding is complete ...

1 files changed, 7 insertions, 5 deletions

diff --git a/vespa-feed-client-cli/src/main/java/ai/vespa/feed/client/CliClient.java b/vespa-feed-client-cli/src/main/java/ai/vespa/feed/client/CliClient.java
index 19d1e4332d3..768cdf4c171 100644
--- a/vespa-feed-client-cli/src/main/java/ai/vespa/feed/client/CliClient.java
+++ b/vespa-feed-client-cli/src/main/java/ai/vespa/feed/client/CliClient.java
@@ -60,11 +60,6 @@ public class CliClient {
                 CountDownLatch latch = new CountDownLatch(1);
                 AtomicReference<FeedException> fatal = new AtomicReference<>();
                 long startNanos = System.nanoTime();
-                feeder.feedMany(in, new ResultCallback() {
-                    @Override public void onNextResult(Result result, FeedException error) { handleResult(result, error, cliArgs); }
-                    @Override public void onError(FeedException error) { fatal.set(error); latch.countDown(); }
-                    @Override public void onComplete() { latch.countDown(); }
-                });
                 if (cliArgs.showProgress()) {
                     Thread progressPrinter = new Thread(() -> {
                         try {
@@ -77,7 +72,14 @@ public class CliClient {
                     progressPrinter.setDaemon(true);
                     progressPrinter.start();
                 }
+
+                feeder.feedMany(in, new ResultCallback() {
+                    @Override public void onNextResult(Result result, FeedException error) { handleResult(result, error, cliArgs); }
+                    @Override public void onError(FeedException error) { fatal.set(error); latch.countDown(); }
+                    @Override public void onComplete() { latch.countDown(); }
+                });
                 latch.await();
+
                 if (cliArgs.benchmarkModeEnabled()) {
                     printBenchmarkResult(System.nanoTime() - startNanos, feedClient.stats(), systemOut);
                 }