fixup

remove async execution; previously this method was also called from an Actor thread. Now it is always called from the timer thread and the thread indirection is no longer necessary
camunda · Mar 14, 2022 · cf345b8 · cf345b8
1 parent b1621a4
commit cf345b8
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/engine/src/main/java/io/camunda/zeebe/process/test/engine/EngineStateMonitor.java b/engine/src/main/java/io/camunda/zeebe/process/test/engine/EngineStateMonitor.java
@@ -13,7 +13,6 @@
 import java.util.List;
 import java.util.Timer;
 import java.util.TimerTask;
-import java.util.concurrent.CompletableFuture;
 
 /**
  * Monitor that monitors whether the engine is busy or in idle state. Busy state is a state in which
@@ -67,8 +66,7 @@ private synchronized void scheduleStateNotification() {
   }
 
   private boolean isInIdleState() {
-    return CompletableFuture.supplyAsync(() -> streamProcessor.hasProcessingReachedTheEnd().join())
-        .join();
+    return streamProcessor.hasProcessingReachedTheEnd().join();
   }
 
   @Override