He-Pin commented on code in PR #1776:
URL: https://github.com/apache/pekko/pull/1776#discussion_r1970820484
##########
stream/src/main/scala/org/apache/pekko/stream/stage/GraphStage.scala:
##########
@@ -979,6 +980,26 @@ abstract class GraphStageLogic private[stream] (val
inCount: Int, val outCount:
}
} else andThen()
+ /**
+ * Emit a sequence of elements through the given outlet and continue with
the given thunk
+ * afterwards, suspending execution if necessary.
+ * This action replaces the [[OutHandler]] for the given outlet if suspension
+ * is needed and reinstalls the current handler upon receiving an `onPull()`
+ * signal (before invoking the `andThen` function).
+ */
+ final protected def emitMultiple[T](out: Outlet[T], elems: Spliterator[T],
andThen: () => Unit): Unit = {
Review Comment:
@pjfanning It the same access level as the other `emitMultiple` method, its
been used in a sub class of `GraphStage`
--
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: notifications-unsubscr...@pekko.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscr...@pekko.apache.org
For additional commands, e-mail: notifications-h...@pekko.apache.org
