This is an automated email from the ASF dual-hosted git repository.
hepin 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 1e9a051777 chore: Add since 1.1.0 for `foldWhile` operator (#1335)
1e9a051777 is described below
commit 1e9a051777823e621c804238b05b93fe5e443e5a
Author: He-Pin(kerr) <[email protected]>
AuthorDate: Tue May 21 23:49:36 2024 +0800
chore: Add since 1.1.0 for `foldWhile` operator (#1335)
---
stream/src/main/scala/org/apache/pekko/stream/javadsl/Flow.scala | 2 ++
stream/src/main/scala/org/apache/pekko/stream/javadsl/Sink.scala | 2 ++
stream/src/main/scala/org/apache/pekko/stream/javadsl/SubFlow.scala | 2 ++
stream/src/main/scala/org/apache/pekko/stream/scaladsl/Flow.scala | 2 ++
stream/src/main/scala/org/apache/pekko/stream/scaladsl/Sink.scala | 2 ++
5 files changed, 10 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 fc4ea3e3b3..856a263616 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
@@ -1437,6 +1437,8 @@ final class Flow[In, Out, Mat](delegate:
scaladsl.Flow[In, Out, Mat]) extends Gr
* '''Cancels when''' downstream cancels
*
* See also [[FlowOps.fold]]
+ *
+ * @since 1.1.0
*/
def foldWhile[T](zero: T, p: function.Predicate[T], f: function.Function2[T,
Out, T]): javadsl.Flow[In, T, Mat] =
new Flow(delegate.foldWhile(zero)(p.test)(f.apply))
diff --git a/stream/src/main/scala/org/apache/pekko/stream/javadsl/Sink.scala
b/stream/src/main/scala/org/apache/pekko/stream/javadsl/Sink.scala
index 0805e5df74..a2f24df9dd 100644
--- a/stream/src/main/scala/org/apache/pekko/stream/javadsl/Sink.scala
+++ b/stream/src/main/scala/org/apache/pekko/stream/javadsl/Sink.scala
@@ -57,6 +57,8 @@ object Sink {
* The returned [[java.util.concurrent.CompletionStage]] will be completed
with value of the final
* function evaluation when the input stream ends, predicate `p` returns
false, or completed with `Failure`
* if there is a failure is signaled in the stream.
+ *
+ * @since 1.1.0
*/
def foldWhile[U, In](
zero: U, p: function.Predicate[U], f: function.Function2[U, In, U]):
javadsl.Sink[In, CompletionStage[U]] =
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 ea339fc70f..5fb6bbfdcd 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
@@ -817,6 +817,8 @@ class SubFlow[In, Out, Mat](
* '''Cancels when''' downstream cancels
*
* See also [[FlowOps.fold]]
+ *
+ * @since 1.1.0
*/
def foldWhile[T](zero: T, p: function.Predicate[T], f: function.Function2[T,
Out, T]): SubFlow[In, T, Mat] =
new SubFlow(delegate.foldWhile(zero)(p.test)(f.apply))
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 8d22f29eb9..07ba28c9bf 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
@@ -1844,6 +1844,8 @@ trait FlowOps[+Out, +Mat] {
* '''Cancels when''' downstream cancels
*
* See also [[FlowOps.fold]]
+ *
+ * @since 1.1.0
*/
def foldWhile[T](zero: T)(p: T => Boolean)(f: (T, Out) => T): Repr[T] = via(
Fold[Out, T](zero, p, f).withAttributes(DefaultAttributes.foldWhile))
diff --git a/stream/src/main/scala/org/apache/pekko/stream/scaladsl/Sink.scala
b/stream/src/main/scala/org/apache/pekko/stream/scaladsl/Sink.scala
index 841685e795..c487fbdaee 100644
--- a/stream/src/main/scala/org/apache/pekko/stream/scaladsl/Sink.scala
+++ b/stream/src/main/scala/org/apache/pekko/stream/scaladsl/Sink.scala
@@ -424,6 +424,8 @@ object Sink {
* if there is a failure signaled in the stream.
*
* @see [[#fold]]
+ *
+ * @since 1.1.0
*/
def foldWhile[U, T](zero: U)(p: U => Boolean)(f: (U, T) => U): Sink[T,
Future[U]] =
Flow[T].foldWhile(zero)(p)(f).toMat(Sink.head)(Keep.right).named("foldWhileSink")
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
