diff --git a/akka-stream/src/main/scala/akka/stream/javadsl/Queue.scala b/akka-stream/src/main/scala/akka/stream/javadsl/Queue.scala index 6e50875352..e31e45232b 100644 --- a/akka-stream/src/main/scala/akka/stream/javadsl/Queue.scala +++ b/akka-stream/src/main/scala/akka/stream/javadsl/Queue.scala @@ -23,8 +23,11 @@ trait SourceQueue[T] { * - completes with `Dropped` when stream dropped offered element * - completes with `QueueClosed` when stream is completed during future is active * - completes with `Failure(f)` when failure to enqueue element from upstream - * - fails when stream is completed or you cannot call offer in this moment because of implementation rules - * (like for backpressure mode and full buffer you need to wait for last offer call Future completion) + * - fails when stream is completed + * + * Additionally when using the backpressure overflowStrategy: + * - If the buffer is full the Future won't be completed until there is space in the buffer + * - Calling offer before the Future is completed in this case will return a failed Future * * @param elem element to send to a stream */ diff --git a/akka-stream/src/main/scala/akka/stream/scaladsl/Queue.scala b/akka-stream/src/main/scala/akka/stream/scaladsl/Queue.scala index bf0462de91..e9b91c5f9c 100644 --- a/akka-stream/src/main/scala/akka/stream/scaladsl/Queue.scala +++ b/akka-stream/src/main/scala/akka/stream/scaladsl/Queue.scala @@ -23,8 +23,11 @@ trait SourceQueue[T] { * - completes with `Dropped` when stream dropped offered element * - completes with `QueueClosed` when stream is completed during future is active * - completes with `Failure(f)` when failure to enqueue element from upstream - * - fails when stream is completed or you cannot call offer in this moment because of implementation rules - * (like for backpressure mode and full buffer you need to wait for last offer call Future completion) + * - fails when stream is completed + * + * Additionally when using the backpressure overflowStrategy: + * - If the buffer is full the Future won't be completed until there is space in the buffer + * - Calling offer before the Future is completed in this case will return a failed Future * * @param elem element to send to a stream */