Update akka-stream, akka-testkit to 2.6.4

build.sbt

@@ -25,7 +25,7 @@ lazy val root = (project in file("."))
  scalacOptions in IntegrationTest := (scalacOptions in Compile).value.filterNot(_ == "-Ywarn-dead-code")
  )
 
-val akkaVersion = "2.5.31"
+val akkaVersion = "2.6.4"
 val akkaHttpVersion = "10.1.11"
 
 lazy val akkaDependencies = Seq(
@@ -44,7 +44,7 @@ lazy val awsDependencies = Seq(
 lazy val testDependencies = Seq(
  "org.scalatest" %% "scalatest" % "3.1.1" % Test,
  "org.mockito" %% "mockito-scala" % "1.13.9" % Test,
- "org.mock-server" % "mockserver-netty" % "5.10.0"  % Test
+ "org.mock-server" % "mockserver-netty" % "5.10.0" % Test
 )
 
 lazy val loggingDependencies = Seq(

src/it/scala/io/moia/scalaHttpClient/HeaderExample.scala

@@ -6,7 +6,6 @@ import akka.actor.ActorSystem
 import akka.http.scaladsl.model._
 import akka.http.scaladsl.model.headers.{ModeledCustomHeader, ModeledCustomHeaderCompanion}
 import akka.http.scaladsl.unmarshalling.{Unmarshal, Unmarshaller}
-import akka.stream.ActorMaterializer
 import io.moia.scalaHttpClient.ExampleModel.{DomainErrorObject, GatewayException, MySuccessObject}
 
 import scala.concurrent.duration._
@@ -28,7 +27,6 @@ object HeaderExample {
 
  implicit val system: ActorSystem = ActorSystem("test")
  implicit val executionContext: ExecutionContext = system.dispatcher
- implicit val mat: ActorMaterializer = ActorMaterializer()
  implicit val um1: Unmarshaller[HttpResponse, MySuccessObject] = ???
  implicit val um2: Unmarshaller[HttpResponse, DomainErrorObject] = ???
 

src/it/scala/io/moia/scalaHttpClient/SimpleExample.scala

@@ -5,7 +5,6 @@ import java.time.Clock
 import akka.actor.ActorSystem
 import akka.http.scaladsl.model._
 import akka.http.scaladsl.unmarshalling.{Unmarshal, Unmarshaller}
-import akka.stream.ActorMaterializer
 import io.moia.scalaHttpClient.ExampleModel.{DomainErrorObject, GatewayException, MySuccessObject}
 
 import scala.concurrent.duration._
@@ -21,7 +20,6 @@ object SimpleExample {
 
  implicit val system: ActorSystem = ActorSystem("test")
  implicit val executionContext: ExecutionContext = system.dispatcher
- implicit val mat: ActorMaterializer = ActorMaterializer()
  implicit val um1: Unmarshaller[HttpResponse, MySuccessObject] = ???
  implicit val um2: Unmarshaller[HttpResponse, DomainErrorObject] = ???
 

src/main/scala/io/moia/scalaHttpClient/HttpClient.scala

@@ -6,7 +6,6 @@ import akka.actor.ActorSystem
 import akka.http.scaladsl.Http
 import akka.http.scaladsl.model._
 import akka.http.scaladsl.model.headers.{`Retry-After`, RetryAfterDateTime, RetryAfterDuration}
-import akka.stream.ActorMaterializer
 import com.typesafe.scalalogging.{Logger, LoggerTakingImplicit}
 import org.slf4j.LoggerFactory
 
@@ -128,10 +127,8 @@ abstract class HttpLayer[LoggingContext](
  case other => Future.successful(HttpClientError(other))
  }
 
- private[this] def strictify(response: HttpResponse)(implicit ec: ExecutionContext): Future[HttpResponse] = {
- implicit val materializer: ActorMaterializer = ActorMaterializer()
+ private[this] def strictify(response: HttpResponse)(implicit ec: ExecutionContext): Future[HttpResponse] =
  response.toStrict(retryConfig.strictifyResponseTimeout)
- }
 
  private[this] def retryCount(statusCode: StatusCode)(implicit ctx: LoggingContext): Int = statusCode match {
  case StatusCodes.RequestTimeout => retryConfig.retriesRequestTimeout

src/test/scala/io/moia/scalaHttpClient/AwsRequestSignerTest.scala

@@ -3,7 +3,6 @@ package io.moia.scalaHttpClient
 import akka.actor.ActorSystem
 import akka.http.scaladsl.model.HttpHeader.ParsingResult.Ok
 import akka.http.scaladsl.model.{HttpHeader, HttpRequest, Uri}
-import akka.stream.ActorMaterializer
 import io.moia.scalaHttpClient.AwsRequestSigner.AwsRequestSignerConfig
 import org.scalatest.matchers.should.Matchers
 import org.scalatest.wordspec.AnyWordSpecLike
@@ -12,7 +11,6 @@ import scala.concurrent.duration.{FiniteDuration, _}
 
 class AwsRequestSignerTest extends AnyWordSpecLike with Matchers with FutureValues {
  private implicit val system: ActorSystem = ActorSystem("test")
- private implicit val mat: ActorMaterializer = ActorMaterializer()
  protected implicit val patienceConfig: FiniteDuration = 2.seconds
 
  classOf[AwsRequestSigner].getSimpleName should {

src/test/scala/io/moia/scalaHttpClient/SignableHttpRequestTest.scala

@@ -8,7 +8,6 @@ import akka.actor.ActorSystem
 import akka.http.scaladsl.model.HttpHeader.ParsingResult.Ok
 import akka.http.scaladsl.model.headers.Host
 import akka.http.scaladsl.model.{HttpHeader, HttpRequest, Uri}
-import akka.stream.ActorMaterializer
 import com.amazonaws.auth.{AWS4Signer, BasicAWSCredentials}
 import org.scalatest.matchers.should.Matchers
 import org.scalatest.wordspec.AnyWordSpecLike
@@ -17,7 +16,6 @@ import scala.concurrent.ExecutionContext
 
 class SignableHttpRequestTest extends AnyWordSpecLike with Matchers with FutureValues {
  private implicit def system: ActorSystem = ActorSystem("test")
- private implicit val mat: ActorMaterializer = ActorMaterializer()
  private implicit def executionContext: ExecutionContext = system.dispatcher
  private val amzDateFormat = DateTimeFormatter.ofPattern("yyyyMMdd'T'HHmmssX")
 

src/test/scala/io/moia/scalaHttpClient/TestSetup.scala

@@ -4,15 +4,13 @@ import java.time.Clock
 
 import akka.actor.ActorSystem
 import akka.http.scaladsl.model.{HttpMethod, HttpResponse, Uri}
-import akka.stream.ActorMaterializer
 import org.scalatest.matchers.should.Matchers
 import org.scalatest.wordspec.AnyWordSpecLike
 
 import scala.concurrent.ExecutionContext
 
 trait TestSetup extends AnyWordSpecLike with Matchers with FutureValues {
  implicit val system: ActorSystem = ActorSystem("test")
- implicit val mat: ActorMaterializer = ActorMaterializer()
  implicit val executionContext: ExecutionContext = system.dispatcher
 
  val clock: Clock = Clock.systemUTC()