Add test for typelevel#2842

armanbilge · Mar 10, 2022 · 56582bf · 56582bf
1 parent fad328c
commit 56582bf
Showing 1 changed file with 12 additions and 1 deletion.
diff --git a/core/shared/src/test/scala/fs2/StreamInterruptSuite.scala b/core/shared/src/test/scala/fs2/StreamInterruptSuite.scala
@@ -23,7 +23,7 @@ package fs2
 
 import scala.concurrent.duration._
 
-import cats.effect.{IO, Sync}
+import cats.effect.{IO, IOLocal, Sync}
 import cats.effect.kernel.Deferred
 import cats.effect.std.Semaphore
 import org.scalacheck.effect.PropF.forAllF
@@ -369,4 +369,15 @@ class StreamInterruptSuite extends Fs2Suite {
     val interrupt = IO.sleep(250.millis)
     IO.race(compileWithSync(s).drain, interrupt).map(_.isRight).assert
   }
+
+  test("issue #2842 - no interrupt scope") {
+    val s = Stream.eval(IOLocal(List.empty[Int])).flatMap { local =>
+      Stream.eval(local.update(1 :: _)).flatMap { _ =>
+        Stream.eval(local.update(2 :: _)).flatMap { _ =>
+          Stream.eval(local.get)
+        }
+      }
+    }
+    s.interruptScope.compile.lastOrError.assertEquals(List(2, 1))
+  }
 }