Merge pull request #3938 from armanbilge/issue/3848

Reset auto-cede counter after `blocking`
typelevel · Jan 9, 2024 · e93ee75 · e93ee75
2 parents adc72fe + b442eb2
commit e93ee75
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/core/shared/src/main/scala/cats/effect/IOFiber.scala b/core/shared/src/main/scala/cats/effect/IOFiber.scala
@@ -1005,7 +1005,8 @@ private final class IOFiber[A](
                   }
 
                 val next = if (error eq null) succeeded(r, 0) else failed(error, 0)
-                runLoop(next, nextCancelation, nextAutoCede)
+                // reset auto-cede counter
+                runLoop(next, nextCancelation, runtime.autoYieldThreshold)
               } else {
                 blockingFallback(cur)
               }