diff --git a/http-core/src/main/scala/org/apache/pekko/http/impl/util/StageLoggingWithOverride.scala b/http-core/src/main/scala/org/apache/pekko/http/impl/util/StageLoggingWithOverride.scala index 37df23695..a09a81e62 100644 --- a/http-core/src/main/scala/org/apache/pekko/http/impl/util/StageLoggingWithOverride.scala +++ b/http-core/src/main/scala/org/apache/pekko/http/impl/util/StageLoggingWithOverride.scala @@ -20,7 +20,7 @@ import org.apache.pekko import pekko.annotation.InternalApi import pekko.stream.stage.GraphStageLogic import pekko.event.{ LogSource, LoggingAdapter, NoLogging } -import pekko.stream.{ ActorMaterializer, Materializer } +import pekko.stream.ActorMaterializer // TODO Try to reconcile with what Pekko provides in StageLogging. // We thought this could be removed when https://github.com/akka/akka/issues/18793 had been implemented diff --git a/http-tests/src/test/scala/org/apache/pekko/http/scaladsl/server/DontLeakActorsOnFailingConnectionSpecs.scala b/http-tests/src/test/scala/org/apache/pekko/http/scaladsl/server/DontLeakActorsOnFailingConnectionSpecs.scala index 5c024342c..8668df8d1 100644 --- a/http-tests/src/test/scala/org/apache/pekko/http/scaladsl/server/DontLeakActorsOnFailingConnectionSpecs.scala +++ b/http-tests/src/test/scala/org/apache/pekko/http/scaladsl/server/DontLeakActorsOnFailingConnectionSpecs.scala @@ -25,6 +25,7 @@ import pekko.stream.scaladsl.{ Sink, Source } import pekko.stream.testkit.Utils.assertAllStagesStopped import pekko.testkit.TestKit import com.typesafe.config.ConfigFactory +import org.apache.pekko.stream.ActorMaterializer import org.scalatest.BeforeAndAfterAll import scala.concurrent.Await @@ -47,6 +48,7 @@ abstract class DontLeakActorsOnFailingConnectionSpecs(poolImplementation: String http.host-connection-pool.base-connection-backoff = 0 ms }""").withFallback(ConfigFactory.load()) implicit val system: ActorSystem = ActorSystem("DontLeakActorsOnFailingConnectionSpecs-" + poolImplementation, config) + implicit val materializer: ActorMaterializer = ActorMaterializer() val log = Logging(system, getClass)(LogSource.fromClass)