Use FiberRuntime#unsafe.addObserver for bincompat with v2.1

zio · Apr 17, 2024 · 891df52 · 891df52
1 parent 772233b
commit 891df52
Showing 1 changed file with 2 additions and 2 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
@@ -431,12 +431,12 @@ private abstract class ZioConcurrent[R, E, E1]
       ZIO
         .async[R, E3, C](
           { cb =>
-            leftFiber.addObserver { _ =>
+            leftFiber.unsafe.addObserver { _ =>
               complete(leftFiber, rightFiber, leftWins, raceIndicator, cb)
               ()
             }(Unsafe.unsafe)
 
-            rightFiber.addObserver { _ =>
+            rightFiber.unsafe.addObserver { _ =>
               complete(rightFiber, leftFiber, rightWins, raceIndicator, cb)
               ()
             }(Unsafe.unsafe)