Replaced forEach() with subscribe(logger::info) in Simulator

AxonIQ · Apr 24, 2024 · 0926557 · 0926557
1 parent ea3c6b0
commit 0926557
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/rental/src/main/java/io/axoniq/demo/bikerental/rental/ui/Simulator.java b/rental/src/main/java/io/axoniq/demo/bikerental/rental/ui/Simulator.java
@@ -97,6 +97,6 @@ private void generateRentals() {
                 this.loops,
                 this.concurrency,
                 this.abandonPaymentFactor,
-                this.delayBetweenLoops).toStream().forEach(logger::info);
+                this.delayBetweenLoops).subscribe(logger::info);
     }
 }