Corrected documentation (#26159)

2019-01-17 12:16:52 +01:00 · 2019-01-17 12:16:52 +01:00 · 67902d82bc
commit 67902d82bc
parent 89a547f690
3 changed files with 6 additions and 6 deletions
--- 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)