From 54171b21047a6efd76b018ee53fb46ffc079025d Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Luis=20Miguel=20Mej=C3=ADa=20Su=C3=A1rez?=
 <luismiguelmejiasuarez@gmail.com>
Date: Mon, 12 Feb 2024 12:13:51 -0500
Subject: [PATCH] Mask interop.flow.StreamSubscription.run

---
 .../src/main/scala/fs2/interop/flow/StreamSubscription.scala     | 1 +
 1 file changed, 1 insertion(+)

diff --git a/core/shared/src/main/scala/fs2/interop/flow/StreamSubscription.scala b/core/shared/src/main/scala/fs2/interop/flow/StreamSubscription.scala
index a076752b73..5e6ef43120 100644
--- 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 {