raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

chore: Add @since 1.1.0 to contramap operator.

Browse source
This commit is contained in:
He-Pin 2024-01-14 21:59:10 +08:00 • committed by kerr
parent 447728f3c0
commit 43bab55616
4 changed files with 4 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

1
stream/src/main/scala/org/apache/pekko/stream/javadsl/Flow.scala
View file

@ -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)))

1
stream/src/main/scala/org/apache/pekko/stream/javadsl/Sink.scala
View file

@ -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])

1
stream/src/main/scala/org/apache/pekko/stream/scaladsl/Flow.scala
View file

@ -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)

1
stream/src/main/scala/org/apache/pekko/stream/scaladsl/Sink.scala
View file

@ -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)