pjfanning commented on code in PR #1824:
URL: https://github.com/apache/pekko/pull/1824#discussion_r2051776092
##########
stream/src/main/scala/org/apache/pekko/stream/javadsl/SubFlow.scala:
##########
@@ -714,6 +714,40 @@ class SubFlow[In, Out, Mat](
def sliding(n: Int, step: Int = 1): SubFlow[In, java.util.List[Out
@uncheckedVariance], Mat] =
new SubFlow(delegate.sliding(n, step).map(_.asJava)) // TODO optimize to
one step
+ /**
+ * Collect subsequent repetitions of an element (that is, if they arrive
right after one another) into multiple
+ * `List` buffers that will be emitted by the resulting SubFlow.
+ *
+ * @return a SubFlow that buffers elements until they change
Review Comment:
add `@since 1.2.0` to new public methods
--
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]
