scalafmt

typelevel · Oct 9, 2021 · 5ab1f90 · 5ab1f90
1 parent 71911a5
commit 5ab1f90
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/core/shared/src/main/scala/fs2/Stream.scala b/core/shared/src/main/scala/fs2/Stream.scala
@@ -2046,9 +2046,9 @@ final class Stream[+F[_], +O] private[fs2] (private[fs2] val underlying: Pull[F,
   private def parEvalMapAction[F2[x] >: F[
     x
   ]: Concurrent, O2, T](
-    maxConcurrent: Int,
-    f: O => F2[O2],
-  )(init: Channel[F2, F2[O2]] => F2[O2 => F2[Unit]]): Stream[F2, O2] =
+      maxConcurrent: Int,
+      f: O => F2[O2]
+  )(initFork: Channel[F2, F2[O2]] => F2[O2 => F2[Unit]]): Stream[F2, O2] =
     if (maxConcurrent == 1) evalMap(f)
     else {
       assert(maxConcurrent > 0, "maxConcurrent must be > 0, was: " + maxConcurrent)
@@ -2096,7 +2096,7 @@ final class Stream[+F[_], +O] private[fs2] (private[fs2] val underlying: Pull[F,
 
           def forkOnElem(el: O): F2[Unit] =
             semaphore.acquire *>
-              init(channel).flatMap { send =>
+              initFork(channel).flatMap { send =>
                 f(el).attempt
                   .race(stopReading.get)
                   .flatMap {