From 43bab55616f40c0cf5ece07d8cd07110a3027c7d Mon Sep 17 00:00:00 2001 From: He-Pin Date: Sun, 14 Jan 2024 21:59:10 +0800 Subject: [PATCH] chore: Add @since 1.1.0 to contramap operator. --- stream/src/main/scala/org/apache/pekko/stream/javadsl/Flow.scala | 1 + stream/src/main/scala/org/apache/pekko/stream/javadsl/Sink.scala | 1 + .../src/main/scala/org/apache/pekko/stream/scaladsl/Flow.scala | 1 + .../src/main/scala/org/apache/pekko/stream/scaladsl/Sink.scala | 1 + 4 files changed, 4 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 030f3ebfa4..659ac20073 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 @@ -539,6 +539,7 @@ final class Flow[In, Out, Mat](delegate: scaladsl.Flow[In, Out, Mat]) extends Gr * '''Backpressures when''' original [[Flow]] backpressures * * '''Cancels when''' original [[Flow]] cancels + * @since 1.1.0 */ def contramap[In2](f: function.Function[In2, In]): javadsl.Flow[In2, Out, Mat] = new Flow(delegate.contramap(elem => f(elem))) 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 7bbbcd782f..c71f433847 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 @@ -568,6 +568,7 @@ final class Sink[In, Mat](delegate: scaladsl.Sink[In, Mat]) extends Graph[SinkSh * '''Backpressures when''' original [[Sink]] backpressures * * '''Cancels when''' original [[Sink]] backpressures + * @since 1.1.0 */ def contramap[In2](f: function.Function[In2, In]): Sink[In2, Mat] = javadsl.Flow.fromFunction(f).toMat(this, Keep.right[NotUsed, Mat]) 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 5113ca20d2..5e67b9b7a8 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 @@ -179,6 +179,7 @@ final class Flow[-In, +Out, +Mat]( * '''Backpressures when''' original [[Flow]] backpressures * * '''Cancels when''' original [[Flow]] cancels + * @since 1.1.0 */ def contramap[In2](f: In2 => In): Flow[In2, Out, Mat] = Flow.fromFunction(f).viaMat(this)(Keep.right) 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 3bd5c9d871..935796a478 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 @@ -56,6 +56,7 @@ final class Sink[-In, +Mat](override val traversalBuilder: LinearTraversalBuilde * '''Backpressures when''' original [[Sink]] backpressures * * '''Cancels when''' original [[Sink]] cancels + * @since 1.1.0 */ def contramap[In2](f: In2 => In): Sink[In2, Mat] = Flow.fromFunction(f).toMat(this)(Keep.right)