diff --git a/akka-docs/src/main/paradox/stream/stream-introduction.md b/akka-docs/src/main/paradox/stream/stream-introduction.md
index 8cb37656c1..2d2a3e712e 100644
--- a/akka-docs/src/main/paradox/stream/stream-introduction.md
+++ b/akka-docs/src/main/paradox/stream/stream-introduction.md
@@ -18,8 +18,8 @@ another. We have found it tedious and error-prone to implement all the proper
 measures in order to achieve stable streaming between actors, since in addition
 to sending and receiving we also need to take care to not overflow any buffers
 or mailboxes in the process. Another pitfall is that Actor messages can be lost
-and must be retransmitted in that case lest the stream have holes on the
-receiving side. When dealing with streams of elements of a fixed given type,
+and must be retransmitted in that case. Failure to do so would lead to holes at
+the receiving side. When dealing with streams of elements of a fixed given type,
 Actors also do not currently offer good static guarantees that no wiring errors
 are made: type-safety could be improved in this case.
 
diff --git a/akka-docs/src/test/java/jdocs/stream/IntegrationDocTest.java b/akka-docs/src/test/java/jdocs/stream/IntegrationDocTest.java
index 3f2cc87717..5186123020 100644
--- a/akka-docs/src/test/java/jdocs/stream/IntegrationDocTest.java
+++ b/akka-docs/src/test/java/jdocs/stream/IntegrationDocTest.java
@@ -752,8 +752,8 @@ public class IntegrationDocTest extends AbstractJavaTest {
     new TestKit(system) {
       {
         // #source-queue
-        int bufferSize = 5;
-        int elementsToProcess = 3;
+        int bufferSize = 10;
+        int elementsToProcess = 5;
 
         SourceQueueWithComplete<Integer> sourceQueue =
             Source.<Integer>queue(bufferSize, OverflowStrategy.backpressure())
diff --git a/akka-docs/src/test/scala/docs/stream/IntegrationDocSpec.scala b/akka-docs/src/test/scala/docs/stream/IntegrationDocSpec.scala
index 0c640d5857..62982fdf64 100644
--- a/akka-docs/src/test/scala/docs/stream/IntegrationDocSpec.scala
+++ b/akka-docs/src/test/scala/docs/stream/IntegrationDocSpec.scala
@@ -475,8 +475,8 @@ class IntegrationDocSpec extends AkkaSpec(IntegrationDocSpec.config) {
 
   "illustrate use of source queue" in {
     //#source-queue
-    val bufferSize = 5
-    val elementsToProcess = 3
+    val bufferSize = 10
+    val elementsToProcess = 5
 
     val queue = Source
       .queue[Int](bufferSize, OverflowStrategy.backpressure)