Merge pull request #2412 from mpilquist/bugfix/2408

Fix memory leak in Channel
typelevel · May 20, 2021 · bf73c02 · bf73c02
2 parents fb1b6f9 + 0b7360a
commit bf73c02
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/core/shared/src/main/scala/fs2/concurrent/Channel.scala b/core/shared/src/main/scala/fs2/concurrent/Channel.scala
@@ -209,7 +209,8 @@ object Channel {
                     (
                       State(values, size, waiting.some, producers, closed),
                       F.pure(
-                        (Pull.eval(waiting.get) >> consumeLoop).unlessA(closed)
+                        if (closed) Pull.done
+                        else (Pull.eval(waiting.get) >> consumeLoop)
                       )
                     )
                   }