Fix memory leak issue in ZIOConcurrent (#688)

* OnInterrupt added * interruptFork
zio · Feb 17, 2024 · 660c3b7 · 660c3b7
1 parent b49e9d2
commit 660c3b7
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/build.sbt b/build.sbt
@@ -51,7 +51,7 @@ lazy val root = project
     unusedCompileDependenciesFilter -= moduleFilter("org.scala-js", "scalajs-library")
   )
 
-val zioVersion                 = "2.0.16"
+val zioVersion                 = "2.0.21"
 val catsVersion                = "2.9.0"
 val catsEffectVersion          = "3.4.8"
 val catsMtlVersion             = "1.3.0"

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
@@ -447,6 +447,12 @@ private abstract class ZioConcurrent[R, E, E1]
           },
           leftFiber.id <> rightFiber.id
         )
+        .onInterrupt(
+          leftFiber.interruptFork *>
+            rightFiber.interruptFork *>
+            leftFiber.await *>
+            rightFiber.await
+        )
     }
 }