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

=str #25043 using materializer.executionContext in UnfoldResourceSourceAsync (#25114)

Browse source
This commit is contained in:
Stefano Bonetti 2018-05-17 12:17:33 +01:00 • committed by Konrad `ktoso` Malawski
parent b27bdba13b
commit f8ed3df013
1 changed files with 1 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-stream/src/main/scala/akka/stream/impl/UnfoldResourceSourceAsync.scala
View file

@ -29,7 +29,7 @@ import scala.util.control.NonFatal
def createLogic(inheritedAttributes: Attributes) = new GraphStageLogic(shape) with OutHandler { def createLogic(inheritedAttributes: Attributes) = new GraphStageLogic(shape) with OutHandler {
lazy val decider = inheritedAttributes.mandatoryAttribute[SupervisionStrategy].decider lazy val decider = inheritedAttributes.mandatoryAttribute[SupervisionStrategy].decider
private implicit def ec = ActorMaterializerHelper.downcast(materializer).system.dispatcher private implicit def ec = materializer.executionContext
private var state: Option[S] = None private var state: Option[S] = None
private val createdCallback = getAsyncCallback[Try[S]] { private val createdCallback = getAsyncCallback[Try[S]] {