This is an automated email from the ASF dual-hosted git repository.
fanningpj pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pekko-connectors.git
The following commit(s) were added to refs/heads/main by this push:
new 7bd538a11 PekkoHttpClient doesn't need a Materializer (#1257)
7bd538a11 is described below
commit 7bd538a11ac4816206201949ef79081e818da679
Author: PJ Fanning <[email protected]>
AuthorDate: Wed Oct 22 14:02:02 2025 +0100
PekkoHttpClient doesn't need a Materializer (#1257)
---
.../apache/pekko/stream/connectors/awsspi/PekkoHttpClient.scala | 7 ++-----
1 file changed, 2 insertions(+), 5 deletions(-)
diff --git
a/aws-spi-pekko-http/src/main/scala/org/apache/pekko/stream/connectors/awsspi/PekkoHttpClient.scala
b/aws-spi-pekko-http/src/main/scala/org/apache/pekko/stream/connectors/awsspi/PekkoHttpClient.scala
index 0c9885d1d..eb7d1764b 100644
---
a/aws-spi-pekko-http/src/main/scala/org/apache/pekko/stream/connectors/awsspi/PekkoHttpClient.scala
+++
b/aws-spi-pekko-http/src/main/scala/org/apache/pekko/stream/connectors/awsspi/PekkoHttpClient.scala
@@ -33,7 +33,6 @@ import pekko.http.scaladsl.model._
import pekko.http.scaladsl.model.headers.{ `Content-Length`, `Content-Type` }
import pekko.http.scaladsl.settings.ConnectionPoolSettings
import pekko.stream.scaladsl.Source
-import pekko.stream.{ Materializer, SystemMaterializer }
import pekko.util.ByteString
import org.slf4j.LoggerFactory
import software.amazon.awssdk.http.async._
@@ -53,8 +52,7 @@ class PekkoHttpClient(
)(
implicit
actorSystem: ActorSystem,
- ec: ExecutionContext,
- mat: Materializer) extends SdkAsyncHttpClient {
+ ec: ExecutionContext) extends SdkAsyncHttpClient {
import PekkoHttpClient._
lazy val runner = new RequestRunner()
@@ -186,7 +184,6 @@ object PekkoHttpClient {
def buildWithDefaults(serviceDefaults: AttributeMap): SdkAsyncHttpClient =
{
implicit val as = actorSystem.getOrElse(ActorSystem("aws-pekko-http"))
implicit val ec = executionContext.getOrElse(as.dispatcher)
- val mat: Materializer = SystemMaterializer(as).materializer
val resolvedOptions =
serviceDefaults.merge(SdkHttpConfigurationOption.GLOBAL_HTTP_DEFAULTS);
@@ -207,7 +204,7 @@ object PekkoHttpClient {
}
()
}
- new PekkoHttpClient(shutdownhandleF, cps, connectionContext)(as, ec, mat)
+ new PekkoHttpClient(shutdownhandleF, cps, connectionContext)(as, ec)
}
def withActorSystem(actorSystem: ActorSystem): PekkoHttpClientBuilder =
copy(actorSystem = Some(actorSystem))
def withActorSystem(actorSystem: ClassicActorSystemProvider):
PekkoHttpClientBuilder =
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
