From 5ab1f90f2c20e434c3458f49a321a0c97526a82f Mon Sep 17 00:00:00 2001
From: nikiforo <anikiforov@delimobil.ru>
Date: Sat, 9 Oct 2021 18:20:39 +0300
Subject: [PATCH] scalafmt

---
 core/shared/src/main/scala/fs2/Stream.scala | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/core/shared/src/main/scala/fs2/Stream.scala b/core/shared/src/main/scala/fs2/Stream.scala
index 6efe5b934a..9d6314d535 100644
--- 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 {