From f8ed3df01329bf17d1ba9d0d72c0d2c5df55b77d Mon Sep 17 00:00:00 2001 From: Stefano Bonetti Date: Thu, 17 May 2018 12:17:33 +0100 Subject: [PATCH] =str #25043 using materializer.executionContext in UnfoldResourceSourceAsync (#25114) --- .../main/scala/akka/stream/impl/UnfoldResourceSourceAsync.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/akka-stream/src/main/scala/akka/stream/impl/UnfoldResourceSourceAsync.scala b/akka-stream/src/main/scala/akka/stream/impl/UnfoldResourceSourceAsync.scala index f7f9eb3935..7c143d0c04 100644 --- a/akka-stream/src/main/scala/akka/stream/impl/UnfoldResourceSourceAsync.scala +++ b/akka-stream/src/main/scala/akka/stream/impl/UnfoldResourceSourceAsync.scala @@ -29,7 +29,7 @@ import scala.util.control.NonFatal def createLogic(inheritedAttributes: Attributes) = new GraphStageLogic(shape) with OutHandler { 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 val createdCallback = getAsyncCallback[Try[S]] {