Use all instead of compile.stream.toList

lichess-org · Nov 27, 2024 · cd4a648 · cd4a648
1 parent 43d47d8
commit cd4a648
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/modules/ingestor/src/main/scala/mongo.chapter.scala b/modules/ingestor/src/main/scala/mongo.chapter.scala
@@ -108,8 +108,6 @@ object ChapterRepo:
     def byStudyIds(ids: List[String]): IO[Map[String, StudyData]] =
       coll
         .aggregateWithCodec[StudyData](Query.aggregate(ids))
-        .stream
-        .compile
-        .toList
+        .all
         .flatTap(docs => Logger[IO].debug(s"Received $docs chapters"))
         .map(_.map(x => x._id -> x).toMap)