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

=str #19818 Flow.transform should be deprected too

Browse source
This commit is contained in:
Alexander Golubev 2016-02-20 15:41:51 -05:00
parent b37c2c0b29
commit c7c4ced93a
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

@ -991,6 +991,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
* 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] =
new Flow(delegate.transform(() ⇒ mkStage.create()))

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

@ -1433,6 +1433,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
* 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] =
new Source(delegate.transform(() ⇒ mkStage.create()))

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

@ -839,6 +839,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
* 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] =
new SubFlow(delegate.transform(() ⇒ mkStage.create()))

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

@ -837,6 +837,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
* 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] =
new SubSource(delegate.transform(() ⇒ mkStage.create()))

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

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