#264 Fix fiber interrupted issue in Bulkhead (#265)

.fork.toManaged_ does not behave the same as .forkManaged (= .toManaged_.fork)
svroonland · Jul 21, 2022 · dddeb6c · dddeb6c
1 parent 85b16ae
commit dddeb6c
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/rezilience/shared/src/main/scala/nl/vroste/rezilience/Bulkhead.scala b/rezilience/shared/src/main/scala/nl/vroste/rezilience/Bulkhead.scala
@@ -88,8 +88,7 @@ object Bulkhead {
                                onStart.bracket_(onEnd, task)
                              }
                              .runDrain
-                             .fork
-                             .toManaged_
+                             .forkManaged
     } yield new Bulkhead {
       override def apply[R, E, A](task: ZIO[R, E, A]): ZIO[R, BulkheadError[E], A] =
         for {