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(_))