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

Make broadcast cancellation configurable

Browse source
This commit is contained in:
Endre Sándor Varga 2015-06-24 14:44:07 +02:00
parent 8c6223e878
commit df35562c0b
6 changed files with 28 additions and 12 deletions
Download patch file Download diff file Expand all files Collapse all files

4
akka-stream/src/main/scala/akka/stream/impl/ActorMaterializerImpl.scala
View file

@ -173,8 +173,8 @@ private[akka] case class ActorMaterializerImpl(
val flexi = r.flexi(r.shape)
(FlexiRoute.props(effectiveSettings, r.shape, flexi), r.shape.inlets.head: InPort, r.shape.outlets)
case BroadcastModule(shape, _) ⇒
(Broadcast.props(effectiveSettings, shape.outArray.size), shape.in, shape.outArray.toSeq)
case BroadcastModule(shape, eagerCancel, _) ⇒
(Broadcast.props(effectiveSettings, eagerCancel, shape.outArray.size), shape.in, shape.outArray.toSeq)
case BalanceModule(shape, waitForDownstreams, _) ⇒
(Balance.props(effectiveSettings, shape.outArray.size, waitForDownstreams), shape.in, shape.outArray.toSeq)