interruptFork

zio · Feb 17, 2024 · 2885562 · 2885562
1 parent 73993e0
commit 2885562
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/zio-interop-cats/shared/src/main/scala/zio/interop/cats.scala b/zio-interop-cats/shared/src/main/scala/zio/interop/cats.scala
@@ -448,9 +448,10 @@ private abstract class ZioConcurrent[R, E, E1]
           leftFiber.id <> rightFiber.id
         )
         .onInterrupt(
-          leftFiber.interruptAsFork(parentFiber.id) *> rightFiber.interruptAsFork(
-            parentFiber.id
-          ) *> leftFiber.await *> rightFiber.await
+          leftFiber.interruptFork *>
+            rightFiber.interruptFork *>
+            leftFiber.await *>
+            rightFiber.await
         )
     }
 }