Add foldLeft

danslapman · danslapman · commit 349278ed17c5 · 2017-12-10T12:16:48.000+03:00
diff --git a/src/main/scala/asyncstreams/AsyncStream.scala b/src/main/scala/asyncstreams/AsyncStream.scala
@@ -85,6 +85,9 @@ class AsyncStream[F[+_]: Monad, +A](private[asyncstreams] val data: F[Step[A, As
 
   def zipWithIndex(implicit app: Applicative[AsyncStream[F, ?]]): AsyncStream[F, (A, Int)] =
     zip(AsyncStream.unfold(0)(_ + 1))
+
+  def foldLeft[B](init: B)(fold: (B, A) => B)(implicit impl: ASImpl[F]): F[B] =
+    impl.collectLeft(this)(init)(fold)
 }
 
 object AsyncStream {

Original file line number	Diff line number	Diff line change
`@@ -85,6 +85,9 @@ class AsyncStream[F[+_]: Monad, +A](private[asyncstreams] val data: F[Step[A, As`
`85`	`85`
`86`	`86`	`def zipWithIndex(implicit app: Applicative[AsyncStream[F, ?]]): AsyncStream[F, (A, Int)] =`
`87`	`87`	`zip(AsyncStream.unfold(0)(_ + 1))`
	`88`	`+`
	`89`	`+ def foldLeft[B](init: B)(fold: (B, A) => B)(implicit impl: ASImpl[F]): F[B] =`
	`90`	`+ impl.collectLeft(this)(init)(fold)`
`88`	`91`	`}`
`89`	`92`
`90`	`93`	`object AsyncStream {`