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

=str Don't create closure

Browse source
This commit is contained in:
hepin1989 2020-03-22 11:19:18 +08:00
parent 7f2773024f
commit 92cbec8568
1 changed files with 2 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -228,7 +228,7 @@ private[akka] class SubFusingActorMaterializerImpl(
implicit val ec = context.dispatcher implicit val ec = context.dispatcher
override def supervisorStrategy: SupervisorStrategy = SupervisorStrategy.stoppingStrategy override def supervisorStrategy: SupervisorStrategy = SupervisorStrategy.stoppingStrategy
def receive = { def receive: Receive = {
case Materialize(props, name) => case Materialize(props, name) =>
val impl = context.actorOf(props, name) val impl = context.actorOf(props, name)
sender() ! impl sender() ! impl
@ -243,7 +243,6 @@ private[akka] class SubFusingActorMaterializerImpl(
} }
def takeSnapshotsOfChildren(): Future[immutable.Seq[StreamSnapshot]] = { def takeSnapshotsOfChildren(): Future[immutable.Seq[StreamSnapshot]] = {
implicit val scheduler = context.system.scheduler
// Arbitrary timeout but should always be quick, the failure scenario is that // Arbitrary timeout but should always be quick, the failure scenario is that
// the child/stream stopped, and we do retry below // the child/stream stopped, and we do retry below
implicit val timeout: Timeout = 1.second implicit val timeout: Timeout = 1.second
@ -255,7 +254,7 @@ private[akka] class SubFusingActorMaterializerImpl(
// If the timeout hits it is likely because one of the streams stopped between looking at the list // If the timeout hits it is likely because one of the streams stopped between looking at the list
// of children and asking it for a snapshot. We retry the entire snapshot in that case // of children and asking it for a snapshot. We retry the entire snapshot in that case
retry(() => takeSnapshot(), 3, Duration.Zero) retry(() => takeSnapshot(), 3)
} }
override def postStop(): Unit = haveShutDown.set(true) override def postStop(): Unit = haveShutDown.set(true)