diff --git a/akka-stream/src/main/scala/akka/stream/javadsl/Flow.scala b/akka-stream/src/main/scala/akka/stream/javadsl/Flow.scala index c294abf16f..aa8440eff2 100644 --- a/akka-stream/src/main/scala/akka/stream/javadsl/Flow.scala +++ b/akka-stream/src/main/scala/akka/stream/javadsl/Flow.scala @@ -1213,10 +1213,12 @@ final class Flow[-In, +Out, +Mat](delegate: scaladsl.Flow[In, Out, Mat]) extends * * '''Emits when''' downstream stops backpressuring and there is a pending element in the buffer * - * '''Backpressures when''' depending on OverflowStrategy - * * Backpressure - backpressures when buffer is full - * * DropHead, DropTail, DropBuffer - never backpressures - * * Fail - fails the stream if buffer gets full + * '''Backpressures when''' downstream backpressures or depending on OverflowStrategy: + * * * '''Completes when''' upstream completes and buffered elements have been drained * 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 d3adfa1d0e..48cabd578b 100644 --- a/akka-stream/src/main/scala/akka/stream/javadsl/Source.scala +++ b/akka-stream/src/main/scala/akka/stream/javadsl/Source.scala @@ -1754,10 +1754,12 @@ final class Source[+Out, +Mat](delegate: scaladsl.Source[Out, Mat]) extends Grap * * '''Emits when''' downstream stops backpressuring and there is a pending element in the buffer * - * '''Backpressures when''' depending on OverflowStrategy - * * Backpressure - backpressures when buffer is full - * * DropHead, DropTail, DropBuffer - never backpressures - * * Fail - fails the stream if buffer gets full + * '''Backpressures when''' downstream backpressures or depending on OverflowStrategy: + * * * '''Completes when''' upstream completes and buffered elements has been drained * diff --git a/akka-stream/src/main/scala/akka/stream/javadsl/SubFlow.scala b/akka-stream/src/main/scala/akka/stream/javadsl/SubFlow.scala index 8a4dfec486..f545fb98c6 100644 --- a/akka-stream/src/main/scala/akka/stream/javadsl/SubFlow.scala +++ b/akka-stream/src/main/scala/akka/stream/javadsl/SubFlow.scala @@ -958,10 +958,12 @@ class SubFlow[-In, +Out, +Mat](delegate: scaladsl.SubFlow[Out, Mat, scaladsl.Flo * * '''Emits when''' downstream stops backpressuring and there is a pending element in the buffer * - * '''Backpressures when''' depending on OverflowStrategy - * * Backpressure - backpressures when buffer is full - * * DropHead, DropTail, DropBuffer - never backpressures - * * Fail - fails the stream if buffer gets full + * '''Backpressures when''' downstream backpressures or depending on OverflowStrategy: + * * * '''Completes when''' upstream completes and buffered elements has been drained * diff --git a/akka-stream/src/main/scala/akka/stream/javadsl/SubSource.scala b/akka-stream/src/main/scala/akka/stream/javadsl/SubSource.scala index a5aa1897ff..9d99235db9 100644 --- a/akka-stream/src/main/scala/akka/stream/javadsl/SubSource.scala +++ b/akka-stream/src/main/scala/akka/stream/javadsl/SubSource.scala @@ -952,10 +952,12 @@ class SubSource[+Out, +Mat](delegate: scaladsl.SubFlow[Out, Mat, scaladsl.Source * * '''Emits when''' downstream stops backpressuring and there is a pending element in the buffer * - * '''Backpressures when''' depending on OverflowStrategy - * * Backpressure - backpressures when buffer is full - * * DropHead, DropTail, DropBuffer - never backpressures - * * Fail - fails the stream if buffer gets full + * '''Backpressures when''' downstream backpressures or depending on OverflowStrategy: + * * * '''Completes when''' upstream completes and buffered elements has been drained * diff --git a/akka-stream/src/main/scala/akka/stream/scaladsl/Flow.scala b/akka-stream/src/main/scala/akka/stream/scaladsl/Flow.scala index 9b263008f4..45b29664b3 100644 --- a/akka-stream/src/main/scala/akka/stream/scaladsl/Flow.scala +++ b/akka-stream/src/main/scala/akka/stream/scaladsl/Flow.scala @@ -1335,10 +1335,12 @@ trait FlowOps[+Out, +Mat] { * * '''Emits when''' downstream stops backpressuring and there is a pending element in the buffer * - * '''Backpressures when''' depending on OverflowStrategy - * * Backpressure - backpressures when buffer is full - * * DropHead, DropTail, DropBuffer - never backpressures - * * Fail - fails the stream if buffer gets full + * '''Backpressures when''' downstream backpressures or depending on OverflowStrategy: + * * * '''Completes when''' upstream completes and buffered elements have been drained *