Update to CE v3.5.0-RC3, FS2 v3.7.0-RC2

build.sbt

@@ -25,8 +25,8 @@ ThisBuild / githubWorkflowBuildPreamble +=
     cond = Some("matrix.project == 'rootNodeJS'")
   )
 
-val ceVersion = "3.4.8"
-val fs2Version = "3.6.1"
+val ceVersion = "3.5.0-RC3"
+val fs2Version = "3.7.0-RC2"
 val sjsDomVersion = "2.4.0"
 val munitCEVersion = "2.0.0-M3"
 val scalaCheckEffectVersion = "2.0.0-M2"

dom/src/main/scala/fs2/dom/StreamConverters.scala

@@ -41,7 +41,8 @@ private[dom] object StreamConverters {
       Stream.bracket(F.delay(readableStream.getReader()))(r => F.delay(r.releaseLock())).flatMap {
         reader =>
           Stream.unfoldChunkEval(reader) { reader =>
-            F.fromPromise(F.delay(reader.read())).map { chunk =>
+            // cleanup on cancellation is handled by outer bracket
+            F.fromPromiseCancelable(F.delay((reader.read(), F.unit))).map { chunk =>
               if (chunk.done)
                 None
               else

tests/src/test/scala/fs2/dom/StreamConversionSuite.scala

@@ -22,6 +22,8 @@ import munit.CatsEffectSuite
 import munit.ScalaCheckEffectSuite
 import org.scalacheck.effect.PropF.forAllF
 
+import scala.concurrent.duration._
+
 class StreamConversionSuite extends CatsEffectSuite with ScalaCheckEffectSuite {
 
   test("to/read ReadableStream") {
@@ -38,4 +40,14 @@ class StreamConversionSuite extends CatsEffectSuite with ScalaCheckEffectSuite {
     }
   }
 
+  test("cancelable") {
+    Stream
+      .never[IO]
+      .through(toReadableStream[IO])
+      .flatMap(readable => readReadableStream(IO(readable)))
+      .compile
+      .drain
+      .timeoutTo(100.millis, IO.unit)
+  }
+
 }