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 5334ea40f6 chore: Fix the @since of Sink.none operator, should be
1.2.0 (#1632)
5334ea40f6 is described below
commit 5334ea40f6865ba1c8fe26e2c09a6632c90e9898
Author: He-Pin(kerr) <[email protected]>
AuthorDate: Sat Dec 28 21:07:03 2024 +0800
chore: Fix the @since of Sink.none operator, should be 1.2.0 (#1632)
---
stream/src/main/scala/org/apache/pekko/stream/javadsl/Sink.scala | 2 +-
stream/src/main/scala/org/apache/pekko/stream/scaladsl/Sink.scala | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
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 41af12379a..8280f0023f 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
@@ -118,7 +118,7 @@ object Sink {
*
* '''Cancels when''' predicate `p` returns `true`
*
- * @since 1.1.3
+ * @since 1.2.0
*/
def none[In](p: function.Predicate[In]): javadsl.Sink[In,
CompletionStage[java.lang.Boolean]] = {
import pekko.util.FutureConverters._
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 653c116ebe..49a52e418d 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
@@ -487,7 +487,7 @@ object Sink {
*
* '''Cancels when''' predicate `p` returns `true`
*
- * @since 1.1.3
+ * @since 1.2.0
*/
def none[T](p: T => Boolean): Sink[T, Future[Boolean]] =
Flow[T].foldWhile(true)(util.ConstantFun.scalaIdentityFunction)(_ && !p(_))
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]