Mask interop.flow.StreamSubscription.run

typelevel · Feb 12, 2024 · 54171b2 · 54171b2
1 parent cc69ced
commit 54171b2
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/core/shared/src/main/scala/fs2/interop/flow/StreamSubscription.scala b/core/shared/src/main/scala/fs2/interop/flow/StreamSubscription.scala
@@ -109,6 +109,7 @@ private[flow] final class StreamSubscription[F[_], A] private (
             // if we were externally canceled, this is handled below
             F.unit
         }
+        .mask
 
     val cancellation = F.asyncCheckAttempt[Unit] { cb =>
       F.delay {