This is an automated email from the ASF dual-hosted git repository.
hepin pushed a commit to branch doOnFirst
in repository https://gitbox.apache.org/repos/asf/pekko.git
The following commit(s) were added to refs/heads/doOnFirst by this push:
new a1870ee5b6 chore: Add since
a1870ee5b6 is described below
commit a1870ee5b6e1e4a2483c143bba4733cbd5db9624
Author: He-Pin <[email protected]>
AuthorDate: Sat Oct 25 16:55:15 2025 +0800
chore: Add since
---
stream/src/main/scala/org/apache/pekko/stream/javadsl/Flow.scala | 4 +++-
stream/src/main/scala/org/apache/pekko/stream/javadsl/Source.scala | 4 +++-
stream/src/main/scala/org/apache/pekko/stream/javadsl/SubFlow.scala | 4 +++-
stream/src/main/scala/org/apache/pekko/stream/javadsl/SubSource.scala | 4 +++-
stream/src/main/scala/org/apache/pekko/stream/scaladsl/Flow.scala | 4 +++-
5 files changed, 15 insertions(+), 5 deletions(-)
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 f6926e37ee..e648aa8a1e 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
@@ -1133,7 +1133,9 @@ final class Flow[In, Out, Mat](delegate:
scaladsl.Flow[In, Out, Mat]) extends Gr
* '''Completes when''' upstream completes
*
* '''Cancels when''' downstream cancels
- * */
+ *
+ * @since 1.3.0
+ */
def doOnFirst(f: function.Procedure[Out]): javadsl.Flow[In, Out, Mat] = new
Flow(delegate.doOnFirst(f(_)))
/**
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 d209ca7e46..70566a2803 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
@@ -2996,7 +2996,9 @@ final class Source[Out, Mat](delegate:
scaladsl.Source[Out, Mat]) extends Graph[
* '''Completes when''' upstream completes
*
* '''Cancels when''' downstream cancels
- * */
+ *
+ * @since 1.3.0
+ */
def doOnFirst(f: function.Procedure[Out]): javadsl.Source[Out, Mat] = new
Source(delegate.doOnFirst(f(_)))
/**
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 d30cabf493..466584943a 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
@@ -535,7 +535,9 @@ final class SubFlow[In, Out, Mat](
* '''Completes when''' upstream completes
*
* '''Cancels when''' downstream cancels
- * */
+ *
+ * @since 1.3.0
+ */
def doOnFirst(f: function.Procedure[Out]): SubFlow[In, Out, Mat] = new
javadsl.SubFlow(delegate.doOnFirst(f(_)))
/**
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 4b846d962e..082717a843 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
@@ -526,7 +526,9 @@ final class SubSource[Out, Mat](
* '''Completes when''' upstream completes
*
* '''Cancels when''' downstream cancels
- * */
+ *
+ * @since 1.3.0
+ */
def doOnFirst(f: function.Procedure[Out]): SubSource[Out, Mat] = new
SubSource(delegate.doOnFirst(f(_)))
/**
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 caad55cb63..528b6c6a7c 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
@@ -1577,7 +1577,9 @@ trait FlowOps[+Out, +Mat] {
* '''Completes when''' upstream completes
*
* '''Cancels when''' downstream cancels
- * */
+ *
+ * @since 1.3.0
+ */
def doOnFirst(f: Out => Unit): Repr[Out] = via(new DoOnFirst[Out](f))
/**
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
