Skip to content

Commit

Permalink
try to fix tests
Browse files Browse the repository at this point in the history
  • Loading branch information
pjfanning committed Oct 29, 2023
1 parent 253e8be commit ce86add
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand All @@ -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)

Expand Down

0 comments on commit ce86add

Please sign in to comment.