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

+str #15205 Java API for FlexiRoute

Browse source
This commit is contained in:
Patrik Nordwall 2014-11-05 20:12:24 +01:00
parent fc941b891c
commit 40371ebde4
6 changed files with 636 additions and 17 deletions
Download patch file Download diff file Expand all files Collapse all files

11
akka-stream/src/main/scala/akka/stream/impl/ActorBasedFlowMaterializer.scala
View file

@ -109,13 +109,12 @@ private[akka] object Ast {
override def name = "concat"
}
case class FlexiMergeNode(merger: FlexiMergeImpl.MergeLogicFactory[Any]) extends FanInAstNode {
override def name = merger.name.getOrElse("flexiMerge")
case class FlexiMergeNode(factory: FlexiMergeImpl.MergeLogicFactory[Any]) extends FanInAstNode {
override def name = factory.name.getOrElse("flexiMerge")
}
case class RouteNode(route: FlexiRoute[Any]) extends FanOutAstNode {
override def name = route.name.getOrElse("route")
case class FlexiRouteNode(factory: FlexiRouteImpl.RouteLogicFactory[Any]) extends FanOutAstNode {
override def name = factory.name.getOrElse("flexiRoute")
}
}
@ -260,7 +259,7 @@ case class ActorBasedFlowMaterializer(override val settings: MaterializerSetting
actorOf(Balance.props(settings, outputCount, waitForAllDownstreams).withDispatcher(settings.dispatcher), actorName)
case Ast.Unzip ⇒
actorOf(Unzip.props(settings).withDispatcher(settings.dispatcher), actorName)
case Ast.RouteNode(route) ⇒
case Ast.FlexiRouteNode(route) ⇒
actorOf(FlexiRouteImpl.props(settings, outputCount, route.createRouteLogic()).
withDispatcher(settings.dispatcher), actorName)
}