- executorService.execute(testListener);
-
- Thread.sleep(10000);
-
- Arrays
- .stream(testWriters)
- .forEach(testClient -> testClient.running = false);
- testListener.running = false;
+ testListener
+ .run()
+ .subscribe(message -> log.info(
+ "Received message: {}",
+ message));
+
+ log.info("Sleeping for 3 seconds...");
+ Thread.sleep(3000);
+
+ for (int i = 0; i < NUM_CLIENTS; i++)
+ {
+ testWriters[i].running = false;
+ testWriterFutures[i].join();
+ log.info("Joined TestWriter {}", testWriters[i].user);
+ }