Check if requests are not empty prior to running them

zio · Mar 29, 2024 · 3bcc616 · 3bcc616
1 parent a294bcd
commit 3bcc616
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/zio-query/shared/src/main/scala/zio/query/DataSource.scala b/zio-query/shared/src/main/scala/zio/query/DataSource.scala
@@ -171,7 +171,7 @@ object DataSource {
     def run(requests: Chunk[A])(implicit trace: Trace): ZIO[R, Nothing, CompletedRequestMap]
     final def runAll(requests: Chunk[Chunk[A]])(implicit trace: Trace): ZIO[R, Nothing, CompletedRequestMap] =
       ZIO.foldLeft(requests)(CompletedRequestMap.empty) { case (completedRequestMap, requests) =>
-        if (completedRequestMap.isEmpty) run(requests)
+        if (completedRequestMap.isEmpty && requests.nonEmpty) run(requests)
         else {
           val newRequests = requests.filterNot(completedRequestMap.contains)
           if (newRequests.isEmpty) ZIO.succeed(completedRequestMap)