Make sure to complete the interruption CB

zio · Jul 25, 2024 · cbe8bc5 · cbe8bc5
1 parent 6e57f13
commit cbe8bc5
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/zio-interop-cats/shared/src/main/scala/zio/interop/package.scala b/zio-interop-cats/shared/src/main/scala/zio/interop/package.scala
@@ -54,7 +54,10 @@ package object interop {
                   fiber.unsafe.removeObserver(completeCb)
                   fiber.tellInterrupt(Cause.interrupt(fiber.id))
                   // Allow the interruption to be interrupted
-                  Some(F.delay(fiber.unsafe.removeObserver(interruptCb)))
+                  Some(F.delay {
+                    fiber.unsafe.removeObserver(interruptCb)
+                    interruptCb(null)
+                  })
                 }
               }))
             case Right(v)    => Right(v) // No need to invoke the callback, sync resumption will take place