Use identity function from Predef

Author: danslapman

src/main/scala/asyncstreams/AsyncStream.scala

@@ -42,7 +42,7 @@ case class AsyncStream[A](data: Future[Step[A, AsyncStream[A]]]) {
     foldLeft(())((_: Unit, a: A) => {f(a); ()})
 
   def foreachF[U](f: (A) => Future[U])(implicit executor: ExecutionContext): Future[Unit] =
-    foldLeft(Future(()))((fu: Future[Unit], a: A) => fu.flatMap(_ => f(a)).map(_ => ())).flatMap(u => u)
+    foldLeft(Future(()))((fu: Future[Unit], a: A) => fu.flatMap(_ => f(a)).map(_ => ())).flatMap(identity)
 
   def flatten[B](implicit asIterable: A => GenIterable[B], executor: ExecutionContext): AsyncStream[B] = {
     val streamChunk = (p: Step[A, AsyncStream[A]]) =>

src/main/scala/asyncstreams/AsyncStreamMonad.scala

@@ -28,7 +28,7 @@ trait AsyncStreamMonadFunctions {
     (implicit ex: ExecutionContext): FState[S, Unit] =
     FState(s => {
       stream.foldLeft(Future(s))((futureS, a) => futureS.flatMap(s2 => f(a)(s2).map(_._2)))
-        .flatMap(f => f).map(((), _))
+        .flatMap(identity).map(((), _))
     })
 
   def isEmpty[A, S](stream: AsyncStream[A])(implicit ex: ExecutionContext): FState[S, Boolean] =