From 3bd53c8bc25c7483fa35190ed452bb63879cd9f6 Mon Sep 17 00:00:00 2001 From: Andrey Kuznetsov Date: Tue, 22 Nov 2016 16:11:09 +0300 Subject: [PATCH] fix SourceQueue docs inconsistencies #21852 --- akka-stream/src/main/scala/akka/stream/javadsl/Source.scala | 5 +++-- akka-stream/src/main/scala/akka/stream/scaladsl/Source.scala | 5 +++-- 2 files changed, 6 insertions(+), 4 deletions(-) diff --git a/akka-stream/src/main/scala/akka/stream/javadsl/Source.scala b/akka-stream/src/main/scala/akka/stream/javadsl/Source.scala index b7b1b24a5b..bfb7642469 100644 --- a/akka-stream/src/main/scala/akka/stream/javadsl/Source.scala +++ b/akka-stream/src/main/scala/akka/stream/javadsl/Source.scala @@ -327,8 +327,9 @@ object Source { * You can watch accessibility of stream with [[akka.stream.javadsl.SourceQueue.watchCompletion]]. * It returns future that completes with success when stream is completed or fail when stream is failed. * - * The buffer can be disabled by using `bufferSize` of 0 and then received message will wait for downstream demand. - * When `bufferSize` is 0 the `overflowStrategy` does not matter. + * The buffer can be disabled by using `bufferSize` of 0 and then received message will wait + * for downstream demand unless there is another message waiting for downstream demand, in that case + * offer result will be completed according to the overflow strategy. * * SourceQueue that current source is materialized to is for single thread usage only. * diff --git a/akka-stream/src/main/scala/akka/stream/scaladsl/Source.scala b/akka-stream/src/main/scala/akka/stream/scaladsl/Source.scala index bbf9065419..dd28350956 100644 --- a/akka-stream/src/main/scala/akka/stream/scaladsl/Source.scala +++ b/akka-stream/src/main/scala/akka/stream/scaladsl/Source.scala @@ -467,8 +467,9 @@ object Source { * You can watch accessibility of stream with [[akka.stream.scaladsl.SourceQueue.watchCompletion]]. * It returns future that completes with success when stream is completed or fail when stream is failed. * - * The buffer can be disabled by using `bufferSize` of 0 and then received message will wait for downstream demand. - * When `bufferSize` is 0 the `overflowStrategy` does not matter. + * The buffer can be disabled by using `bufferSize` of 0 and then received message will wait + * for downstream demand unless there is another message waiting for downstream demand, in that case + * offer result will be completed according to the overflow strategy. * * SourceQueue that current source is materialized to is for single thread usage only. *