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-http.git
The following commit(s) were added to refs/heads/main by this push:
new f720f1719 remove unused implicit var (#725)
f720f1719 is described below
commit f720f17194e9c80ba551e7a2ee217a97c39942d1
Author: PJ Fanning <[email protected]>
AuthorDate: Mon Aug 25 16:04:39 2025 +0100
remove unused implicit var (#725)
---
.../main/scala/org/apache/pekko/http/scaladsl/ClientTransport.scala | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/http-core/src/main/scala/org/apache/pekko/http/scaladsl/ClientTransport.scala
b/http-core/src/main/scala/org/apache/pekko/http/scaladsl/ClientTransport.scala
index 2451ef0e0..283e2779c 100644
---
a/http-core/src/main/scala/org/apache/pekko/http/scaladsl/ClientTransport.scala
+++
b/http-core/src/main/scala/org/apache/pekko/http/scaladsl/ClientTransport.scala
@@ -147,8 +147,8 @@ object ClientTransport {
}.mapMaterializedValue(_.flatten)
}
- private def initFutureFlow[M](flowFactory: () => Future[Flow[ByteString,
ByteString, M]])(
- implicit ec: ExecutionContext): Flow[ByteString, ByteString,
Future[M]] = {
+ private def initFutureFlow[M](
+ flowFactory: () => Future[Flow[ByteString, ByteString, M]]):
Flow[ByteString, ByteString, Future[M]] = {
Flow[ByteString].prepend(Source.single(ByteString()))
.viaMat(
Flow.lazyFutureFlow(flowFactory)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
