diff --git a/akka-docs/src/test/java/jdocs/stream/operators/sourceorflow/Monitor.java b/akka-docs/src/test/java/jdocs/stream/operators/sourceorflow/Monitor.java
index 4a08e1023f..dbce608196 100644
--- a/akka-docs/src/test/java/jdocs/stream/operators/sourceorflow/Monitor.java
+++ b/akka-docs/src/test/java/jdocs/stream/operators/sourceorflow/Monitor.java
@@ -56,24 +56,25 @@ public class Monitor {
 
     // if we peek on the stream too early it probably won't have processed any element.
     printMonitorState(monitor.state());
-    // #monitor
-    // exclude from rendered snippet
-    Thread.sleep(500);
+
+    // At this point, the application will continue to run and future
+    // invocations to `printMonitorState(flowMonitor)` will continue to show
+    // the progress in the stream
     // #monitor
 
-    // ...
+    // Don't use `Thread#sleep` in your code. It's a blocking call
+    // that can starve the thread-pool.
+    Thread.sleep(500);
+
     // sometime later, our code has progressed. We can peek in the stream
     // again to see what's the latest element processed
     printMonitorState(monitor.state());
 
-    // #monitor
-    // exclude from rendered snippet
+    // Don't use `CompletableFuture#get` in your code. It's a blocking call
+    // that can starve the thread-pool.
     run.second().toCompletableFuture().get(1, TimeUnit.SECONDS);
-    // #monitor
-    // #monitor
     // Eventually, the stream completes and if we check the state it reports the streasm finished.
     printMonitorState(monitor.state());
-    // #monitor
 
     run.second().toCompletableFuture().whenComplete((x, t) -> actorSystem.terminate());
   }
diff --git a/akka-docs/src/test/scala/docs/stream/operators/sourceorflow/Monitor.scala b/akka-docs/src/test/scala/docs/stream/operators/sourceorflow/Monitor.scala
index e304ef581e..b90836b02b 100644
--- a/akka-docs/src/test/scala/docs/stream/operators/sourceorflow/Monitor.scala
+++ b/akka-docs/src/test/scala/docs/stream/operators/sourceorflow/Monitor.scala
@@ -50,24 +50,25 @@ class Monitor {
 
   // if we peek on the stream early enough it probably won't have processed any element.
   printMonitorState(flowMonitor)
-  // #monitor
-  // exclude from rendered snippet
-  Thread.sleep(500)
+
+  // At this point, the application will continue to run and future
+  // invocations to `printMonitorState(flowMonitor)` will continue to show
+  // the progress in the stream
   // #monitor
 
-  // ...
+  // Don't use `Thread#sleep` in your code. It's a blocking call
+  // that can starve the thread-pool.
+  Thread.sleep(500)
+
   // sometime later, our code has progressed. We can peek in the stream
   // again to see what's the latest element processed
   printMonitorState(flowMonitor)
 
-  // #monitor
-  // exclude from rendered snippet
+  // Don't use `Await#result` in your code. It's a blocking call
+  // that can starve the thread-pool.
   Await.result(monitoredStream._2, 3.seconds)
-  // #monitor
-  // #monitor
   // Eventually, the stream completes and if we check the state it reports the streasm finished.
   printMonitorState(flowMonitor)
-  // #monitor
 
   monitoredStream._2.onComplete(_ => system.terminate())