Skip to content

Commit 6e698a2

Browse files
authored
remove conversion to Vector (#854)
* remove conversion to Vector * Update Multipart.scala
1 parent 8c958d8 commit 6e698a2

File tree

1 file changed

+2
-3
lines changed
  • http-core/src/main/scala/org/apache/pekko/http/scaladsl/model

1 file changed

+2
-3
lines changed

http-core/src/main/scala/org/apache/pekko/http/scaladsl/model/Multipart.scala

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -217,9 +217,8 @@ object Multipart {
217217
}
218218

219219
private def strictify[BP <: Multipart.BodyPart, BPS <: Multipart.BodyPart.Strict](parts: Source[BP, Any])(
220-
f: BP => Future[BPS])(implicit fm: Materializer): Future[Vector[BPS]] = {
221-
import fm.executionContext
222-
parts.mapAsync(Int.MaxValue)(f).runWith(Sink.seq).fast.map(_.toVector)
220+
f: BP => Future[BPS])(implicit fm: Materializer): Future[Seq[BPS]] = {
221+
parts.mapAsync(Int.MaxValue)(f).runWith(Sink.seq)
223222
}
224223

225224
//////////////////////// CONCRETE multipart types /////////////////////////

0 commit comments

Comments
 (0)