Add result type to Stream#withFilter

typelevel · Sep 17, 2023 · 6fa843f · 6fa843f
1 parent 196995d
commit 6fa843f
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
@@ -2853,7 +2853,7 @@ final class Stream[+F[_], +O] private[fs2] (private[fs2] val underlying: Pull[F,
   /** Alias for [[filter]]
     * Implemented to enable filtering in for comprehensions
     */
-  def withFilter(f: O => Boolean) = this.filter(f)
+  def withFilter(f: O => Boolean): Stream[F, O] = this.filter(f)
 
   private type ZipWithLeft[G[_], I, O2] = (Chunk[I], Stream[G, I]) => Pull[G, O2, Unit]