Remove withFilter usage

zio · Nov 10, 2024 · 7994954 · 7994954
1 parent cc377dd
commit 7994954
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/zio-kafka/src/main/scala/zio/kafka/consumer/internal/Runloop.scala b/zio-kafka/src/main/scala/zio/kafka/consumer/internal/Runloop.scala
@@ -234,7 +234,7 @@ private[consumer] final class Runloop private (
       // Instead, we poll the queue in a loop.
       for {
         _ <- logInitialStreamCompletionStatuses
-        (completed, commits) <-
+        completedAndCommits <-
           ZStream
             .fromZIO(blockingSleep(commitQueuePollInterval) *> commitQueue.takeAll)
             .tap(commitAsync)
@@ -245,7 +245,7 @@ private[consumer] final class Runloop private (
             .takeUntil { case (completed, _) => completed }
             .runLast
             .map(_.getOrElse((false, Chunk.empty)))
-        _ <- logFinalStreamCompletionStatuses(completed, commits)
+        _ <- logFinalStreamCompletionStatuses(completedAndCommits._1, completedAndCommits._2)
         _ <- commitSync
         _ <- ZIO.logDebug(s"Done waiting for ${streamsToEnd.size} streams to end")
       } yield ()