+str #15105 Add Flow tee

2014-05-07 14:15:42 +02:00 · 2014-05-07 14:15:42 +02:00 · ab9b6ea023
commit ab9b6ea023
parent 042ecd00b6
7 changed files with 189 additions and 1 deletions
--- a/akka-stream/src/main/scala/akka/stream/impl/ActorBasedFlowMaterializer.scala
+++ b/akka-stream/src/main/scala/akka/stream/impl/ActorBasedFlowMaterializer.scala
@ -26,6 +26,7 @@ private[akka] object Ast {
  case class Merge(other: Producer[Any]) extends AstNode
  case class Zip(other: Producer[Any]) extends AstNode
  case class Concat(next: Producer[Any]) extends AstNode
+  case class Tee(other: Consumer[Any]) extends AstNode

  trait ProducerNode[I] {
    def createProducer(settings: MaterializerSettings, context: ActorRefFactory): Producer[I]