From 8cdb3feb994c1a4a342a9479216920753452850a Mon Sep 17 00:00:00 2001 From: Dmitry Date: Mon, 30 Apr 2018 03:32:05 +0100 Subject: [PATCH] Use 'same thread' execution context in UnfoldResourceSourceAsync (#24911) --- .../scala/akka/stream/impl/UnfoldResourceSourceAsync.scala | 3 ++- 1 file changed, 2 insertions(+), 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 7a26058109..f7f9eb3935 100644 --- a/akka-stream/src/main/scala/akka/stream/impl/UnfoldResourceSourceAsync.scala +++ b/akka-stream/src/main/scala/akka/stream/impl/UnfoldResourceSourceAsync.scala @@ -6,6 +6,7 @@ package akka.stream.impl import akka.Done import akka.annotation.InternalApi +import akka.dispatch.ExecutionContexts.sameThreadExecutionContext import akka.stream.ActorAttributes.SupervisionStrategy import akka.stream._ import akka.stream.impl.Stages.DefaultAttributes @@ -74,7 +75,7 @@ import scala.util.control.NonFatal state match { case Some(resource) ⇒ try { - readData(resource).onComplete(readCallback) + readData(resource).onComplete(readCallback)(sameThreadExecutionContext) } catch errorHandler case None ⇒ // we got a pull but there is no open resource, we are either