Update zio-kafka/src/main/scala/zio/kafka/consumer/internal/Runloop.s…

…cala Co-authored-by: Jules Ivanic <[email protected]>
zio · Feb 27, 2023 · 240d2c6 · 240d2c6
1 parent 74e079e
commit 240d2c6
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
@@ -562,9 +562,9 @@ private[consumer] final class Runloop(
       case cmd @ Command.ChangeSubscription(_, _, _) =>
         handleChangeSubscription(state, cmd).flatMap { state =>
           if (state.isSubscribed) {
+            // This updates the assignment and will end partition streams which we are no longer subscribed to
             handlePoll(state)
-          } // This updates the assignment and will end partition streams which we are no longer subscribed to
-          else {
+          } else {
             // End pending requests
             endRevoked(state.pendingRequests, state.bufferedRecords, state.assignedStreams, _ => true).as(
               state.copy(