typelevel#1987 Pull.pure is replaced with Pull.done

dmitriibundin · Aug 15, 2020 · d32ac28 · d32ac28
1 parent e3ba608
commit d32ac28
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/core/shared/src/main/scala/fs2/Stream.scala b/core/shared/src/main/scala/fs2/Stream.scala
@@ -1928,7 +1928,7 @@ final class Stream[+F[_], +O] private[fs2] (private val free: FreeC[F, O, Unit])
                       Pull
                         .eval(resultQ.enqueue1(Some(Stream.chunk(hd).onFinalize(guard.release)))) >>
                         go(tl, guard, queue)
-                    case None => Pull.pure(None)
+                    case None => Pull.done
                   }
                 def runStream(
                     s: Stream[F2, O2],