This is an automated email from the ASF dual-hosted git repository.
mdedetrich pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pekko.git
The following commit(s) were added to refs/heads/main by this push:
new b865cf11e0 chore: Add since for newly added methods
b865cf11e0 is described below
commit b865cf11e06ab7206edafbad9c5a2461d1bd3fba
Author: Matthew de Detrich <[email protected]>
AuthorDate: Fri May 2 15:00:11 2025 +0200
chore: Add since for newly added methods
---
stream/src/main/scala/org/apache/pekko/stream/javadsl/Flow.scala | 1 +
stream/src/main/scala/org/apache/pekko/stream/javadsl/Source.scala | 1 +
stream/src/main/scala/org/apache/pekko/stream/javadsl/SubFlow.scala | 1 +
stream/src/main/scala/org/apache/pekko/stream/javadsl/SubSource.scala | 1 +
stream/src/main/scala/org/apache/pekko/stream/scaladsl/Flow.scala | 1 +
stream/src/main/scala/org/apache/pekko/stream/stage/GraphStage.scala | 2 ++
6 files changed, 7 insertions(+)
diff --git a/stream/src/main/scala/org/apache/pekko/stream/javadsl/Flow.scala
b/stream/src/main/scala/org/apache/pekko/stream/javadsl/Flow.scala
index a42e0da27b..d4e0efe69f 100755
--- a/stream/src/main/scala/org/apache/pekko/stream/javadsl/Flow.scala
+++ b/stream/src/main/scala/org/apache/pekko/stream/javadsl/Flow.scala
@@ -1899,6 +1899,7 @@ final class Flow[In, Out, Mat](delegate:
scaladsl.Flow[In, Out, Mat]) extends Gr
* '''Cancels when''' after predicate returned true or downstream cancels
*
* See also [[Flow.limit]], [[Flow.limitWeighted]], [[Flow.takeWhile]]
+ * @since 1.2.0
*/
def takeUntil(p: function.Predicate[Out]): javadsl.Flow[In, Out, Mat] = new
Flow(delegate.takeUntil(p.test))
diff --git a/stream/src/main/scala/org/apache/pekko/stream/javadsl/Source.scala
b/stream/src/main/scala/org/apache/pekko/stream/javadsl/Source.scala
index f55988a1d3..71b73a8005 100755
--- a/stream/src/main/scala/org/apache/pekko/stream/javadsl/Source.scala
+++ b/stream/src/main/scala/org/apache/pekko/stream/javadsl/Source.scala
@@ -3636,6 +3636,7 @@ final class Source[Out, Mat](delegate:
scaladsl.Source[Out, Mat]) extends Graph[
* '''Cancels when''' after predicate returned true or downstream cancels
*
* See also [[Source.limit]], [[Source.limitWeighted]], [[Source.takeWhile]]
+ * @since 1.2.0
*/
def takeUntil(p: function.Predicate[Out]): javadsl.Source[Out, Mat] = new
Source(delegate.takeUntil(p.test))
diff --git
a/stream/src/main/scala/org/apache/pekko/stream/javadsl/SubFlow.scala
b/stream/src/main/scala/org/apache/pekko/stream/javadsl/SubFlow.scala
index c7dc65536b..7dd8eb323f 100755
--- a/stream/src/main/scala/org/apache/pekko/stream/javadsl/SubFlow.scala
+++ b/stream/src/main/scala/org/apache/pekko/stream/javadsl/SubFlow.scala
@@ -1248,6 +1248,7 @@ class SubFlow[In, Out, Mat](
* '''Cancels when''' after predicate returned true or downstream cancels
*
* See also [[FlowOps.limit]], [[FlowOps.limitWeighted]],
[[FlowOps.takeWhile]]
+ * @since 1.2.0
*/
def takeUntil(p: function.Predicate[Out]): SubFlow[In, Out, Mat] = new
SubFlow(delegate.takeUntil(p.test))
diff --git
a/stream/src/main/scala/org/apache/pekko/stream/javadsl/SubSource.scala
b/stream/src/main/scala/org/apache/pekko/stream/javadsl/SubSource.scala
index 19a0b86ddb..e38be6d3f2 100755
--- a/stream/src/main/scala/org/apache/pekko/stream/javadsl/SubSource.scala
+++ b/stream/src/main/scala/org/apache/pekko/stream/javadsl/SubSource.scala
@@ -1137,6 +1137,7 @@ class SubSource[Out, Mat](
* '''Cancels when''' after predicate returned true or downstream cancels
*
* See also [[SubSource.limit]], [[SubSource.limitWeighted]],
[[SubSource.takeWhile]]
+ * @since 1.2.0
*/
def takeUntil(p: function.Predicate[Out]): SubSource[Out, Mat] = new
SubSource(delegate.takeUntil(p.test))
diff --git a/stream/src/main/scala/org/apache/pekko/stream/scaladsl/Flow.scala
b/stream/src/main/scala/org/apache/pekko/stream/scaladsl/Flow.scala
index bfd6010763..abd19e4561 100755
--- a/stream/src/main/scala/org/apache/pekko/stream/scaladsl/Flow.scala
+++ b/stream/src/main/scala/org/apache/pekko/stream/scaladsl/Flow.scala
@@ -1590,6 +1590,7 @@ trait FlowOps[+Out, +Mat] {
* '''Cancels when''' after predicate returned true or downstream cancels
*
* See also [[FlowOps.limit]], [[FlowOps.limitWeighted]],
[[FlowOps.takeWhile]]
+ * @since 1.2.0
*/
def takeUntil(p: Out => Boolean): Repr[Out] = takeWhile(!p(_), inclusive =
true)
diff --git
a/stream/src/main/scala/org/apache/pekko/stream/stage/GraphStage.scala
b/stream/src/main/scala/org/apache/pekko/stream/stage/GraphStage.scala
index b84cef8eff..eb1fb6e001 100644
--- a/stream/src/main/scala/org/apache/pekko/stream/stage/GraphStage.scala
+++ b/stream/src/main/scala/org/apache/pekko/stream/stage/GraphStage.scala
@@ -987,6 +987,8 @@ abstract class GraphStageLogic private[stream] (val
inCount: Int, val outCount:
* 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).
+ *
+ * @since 1.2.0
*/
final protected def emitMultiple[T](out: Outlet[T], elems: Spliterator[T],
andThen: () => Unit): Unit = {
val iter = new EmittingSpliterator[T](out, elems,
getNonEmittingHandler(out), andThen)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
