From 5334ea40f6865ba1c8fe26e2c09a6632c90e9898 Mon Sep 17 00:00:00 2001 From: "He-Pin(kerr)" Date: Sat, 28 Dec 2024 21:07:03 +0800 Subject: [PATCH] chore: Fix the @since of Sink.none operator, should be 1.2.0 (#1632) --- .../src/main/scala/org/apache/pekko/stream/javadsl/Sink.scala | 2 +- .../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(_))