MartinHH commented on code in PR #1787:
URL: https://github.com/apache/pekko/pull/1787#discussion_r1986040387
##########
stream/src/main/scala/org/apache/pekko/stream/scaladsl/Flow.scala:
##########
@@ -2804,6 +2804,25 @@ trait FlowOps[+Out, +Mat] {
def flattenMerge[T, M](breadth: Int)(implicit ev: Out <:<
Graph[SourceShape[T], M]): Repr[T] =
flatMapMerge(breadth, ev)
+ /**
+ * Transforms each input element into a `Source` of output elements that is
+ * then flattened into the output stream until a new input element is
received
+ * at which point the current (now previous) substream is cancelled (which
is why
+ * this operator is sometimes also called "flatMapLatest").
+ *
+ * '''Emits when''' the current substream has an element available
+ *
+ * '''Backpressures when''' never
Review Comment:
On second thought: this might be formally correct as it never backpressures
on upstream (and backpressure on upstream is what is to be adressed here if I'm
not mistaken), but maybe it would be more helpful to mention the backpressure
on substream, e.g.:
```suggestion
* '''Backpressures when''' never on upstream (backpressures on current
substream when downstream backpressures)
```
wdyt?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
