Skip to content

Commit 9a8474d

Browse files
authored
Make async without returned finalizer uninterruptible to conform to cats-effect 3.5 law change (#751)
See typelevel/cats-effect#3725 for details
1 parent 9cf577f commit 9a8474d

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

zio-interop-cats/jvm/src/main/scala/zio/interop/ZioAsync.scala

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -49,8 +49,10 @@ private class ZioAsync[R]
4949

5050
ZIO.uninterruptibleMask(restore =>
5151
k({ e => p.trySuccess(e); () }).flatMap {
52-
case Some(canceler) => onCancel(restore(get), canceler.orDie)
53-
case None => restore(get)
52+
case Some(canceler) => onCancel(restore(get), canceler)
53+
case None =>
54+
// uninterruptible because of https://github.com/typelevel/cats-effect/issues/3725
55+
get
5456
}
5557
)
5658
}

0 commit comments

Comments
 (0)