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 6e698a2a8 remove conversion to Vector (#854)
6e698a2a8 is described below
commit 6e698a2a84ce858c3ae6ecab8a969cc1449ff84d
Author: PJ Fanning <[email protected]>
AuthorDate: Wed Oct 22 16:04:33 2025 +0100
remove conversion to Vector (#854)
* remove conversion to Vector
* Update Multipart.scala
---
.../main/scala/org/apache/pekko/http/scaladsl/model/Multipart.scala | 5 ++---
1 file changed, 2 insertions(+), 3 deletions(-)
diff --git
a/http-core/src/main/scala/org/apache/pekko/http/scaladsl/model/Multipart.scala
b/http-core/src/main/scala/org/apache/pekko/http/scaladsl/model/Multipart.scala
index cbc908d25..48142cefe 100644
---
a/http-core/src/main/scala/org/apache/pekko/http/scaladsl/model/Multipart.scala
+++
b/http-core/src/main/scala/org/apache/pekko/http/scaladsl/model/Multipart.scala
@@ -217,9 +217,8 @@ object Multipart {
}
private def strictify[BP <: Multipart.BodyPart, BPS <:
Multipart.BodyPart.Strict](parts: Source[BP, Any])(
- f: BP => Future[BPS])(implicit fm: Materializer): Future[Vector[BPS]] = {
- import fm.executionContext
- parts.mapAsync(Int.MaxValue)(f).runWith(Sink.seq).fast.map(_.toVector)
+ f: BP => Future[BPS])(implicit fm: Materializer): Future[Seq[BPS]] = {
+ parts.mapAsync(Int.MaxValue)(f).runWith(Sink.seq)
}
//////////////////////// CONCRETE multipart types /////////////////////////
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
