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

Merge pull request #19835 from agolubev/19818-Flow.transform-deprected-agolubev

Browse source 
=str #19818 Flow.transform should be deprected too
This commit is contained in:
drewhk 2016-02-24 17:52:06 +01:00
commit 664071afb6
5 changed files with 5 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

1
akka-stream/src/main/scala/akka/stream/javadsl/Flow.scala
View file

@ -988,6 +988,7 @@ final class Flow[-In, +Out, +Mat](delegate: scaladsl.Flow[In, Out, Mat]) extends
* This operator makes it possible to extend the `Flow` API when there is no specialized * This operator makes it possible to extend the `Flow` API when there is no specialized
* operator that performs the transformation. * operator that performs the transformation.
*/ */
@deprecated("Use via(GraphStage) instead.", "2.4.3")
def transform[U](mkStage: function.Creator[Stage[Out, U]]): javadsl.Flow[In, U, Mat] = def transform[U](mkStage: function.Creator[Stage[Out, U]]): javadsl.Flow[In, U, Mat] =
new Flow(delegate.transform(() ⇒ mkStage.create())) new Flow(delegate.transform(() ⇒ mkStage.create()))

1
akka-stream/src/main/scala/akka/stream/javadsl/Source.scala
View file

@ -1428,6 +1428,7 @@ final class Source[+Out, +Mat](delegate: scaladsl.Source[Out, Mat]) extends Grap
* This operator makes it possible to extend the `Flow` API when there is no specialized * This operator makes it possible to extend the `Flow` API when there is no specialized
* operator that performs the transformation. * operator that performs the transformation.
*/ */
@deprecated("Use via(GraphStage) instead.", "2.4.3")
def transform[U](mkStage: function.Creator[Stage[Out, U]]): javadsl.Source[U, Mat] = def transform[U](mkStage: function.Creator[Stage[Out, U]]): javadsl.Source[U, Mat] =
new Source(delegate.transform(() ⇒ mkStage.create())) new Source(delegate.transform(() ⇒ mkStage.create()))

1
akka-stream/src/main/scala/akka/stream/javadsl/SubFlow.scala
View file

@ -837,6 +837,7 @@ class SubFlow[-In, +Out, +Mat](delegate: scaladsl.SubFlow[Out, Mat, scaladsl.Flo
* This operator makes it possible to extend the `Flow` API when there is no specialized * This operator makes it possible to extend the `Flow` API when there is no specialized
* operator that performs the transformation. * operator that performs the transformation.
*/ */
@deprecated("Use via(GraphStage) instead.", "2.4.3")
def transform[U](mkStage: function.Creator[Stage[Out, U]]): SubFlow[In, U, Mat] = def transform[U](mkStage: function.Creator[Stage[Out, U]]): SubFlow[In, U, Mat] =
new SubFlow(delegate.transform(() ⇒ mkStage.create())) new SubFlow(delegate.transform(() ⇒ mkStage.create()))

1
akka-stream/src/main/scala/akka/stream/javadsl/SubSource.scala
View file

@ -835,6 +835,7 @@ class SubSource[+Out, +Mat](delegate: scaladsl.SubFlow[Out, Mat, scaladsl.Source
* This operator makes it possible to extend the `Flow` API when there is no specialized * This operator makes it possible to extend the `Flow` API when there is no specialized
* operator that performs the transformation. * operator that performs the transformation.
*/ */
@deprecated("Use via(GraphStage) instead.", "2.4.3")
def transform[U](mkStage: function.Creator[Stage[Out, U]]): SubSource[U, Mat] = def transform[U](mkStage: function.Creator[Stage[Out, U]]): SubSource[U, Mat] =
new SubSource(delegate.transform(() ⇒ mkStage.create())) new SubSource(delegate.transform(() ⇒ mkStage.create()))

1
akka-stream/src/main/scala/akka/stream/scaladsl/Flow.scala
View file

@ -1103,6 +1103,7 @@ trait FlowOps[+Out, +Mat] {
* This operator makes it possible to extend the `Flow` API when there is no specialized * This operator makes it possible to extend the `Flow` API when there is no specialized
* operator that performs the transformation. * operator that performs the transformation.
*/ */
@deprecated("Use via(GraphStage) instead.", "2.4.3")
def transform[T](mkStage: () ⇒ Stage[Out, T]): Repr[T] = def transform[T](mkStage: () ⇒ Stage[Out, T]): Repr[T] =
via(new PushPullGraphStage((attr) ⇒ mkStage(), Attributes.none)) via(new PushPullGraphStage((attr) ⇒ mkStage(), Attributes.none))