Run the code formatter on Stream.Reducers

lib/elixir/lib/stream/reducers.ex

@@ -4,7 +4,8 @@ defmodule Stream.Reducers do
 
   def chunk_every(chunk_by, enumerable, count, step, leftover) do
     limit = :erlang.max(count, step)
-    chunk_by.(enumerable, {[], 0}, fn entry, {acc_buffer, acc_count} ->
+
+    chunk_fun = fn entry, {acc_buffer, acc_count} ->
       acc_buffer = [entry | acc_buffer]
       acc_count = acc_count + 1
 
@@ -21,28 +22,37 @@ defmodule Stream.Reducers do
       else
         {:cont, new_state}
       end
-    end, fn {acc_buffer, acc_count} ->
+    end
+
+    after_fun = fn {acc_buffer, acc_count} ->
       if leftover == :discard or acc_count == 0 do
         {:cont, []}
       else
         {:cont, :lists.reverse(acc_buffer, Enum.take(leftover, count - acc_count)), []}
       end
-    end)
+    end
+
+    chunk_by.(enumerable, {[], 0}, chunk_fun, after_fun)
   end
 
   def chunk_by(chunk_by, enumerable, fun) do
-    chunk_by.(enumerable, nil, fn
+    chunk_fun = fn
       entry, nil ->
         {:cont, {[entry], fun.(entry)}}
+
       entry, {acc, value} ->
         case fun.(entry) do
           ^value -> {:cont, {[entry | acc], value}}
           new_value -> {:cont, :lists.reverse(acc), {[entry], new_value}}
         end
-    end, fn
+    end
+
+    after_fun = fn
       nil -> {:cont, :done}
       {acc, _value} -> {:cont, :lists.reverse(acc), :done}
-    end)
+    end
+
+    chunk_by.(enumerable, nil, chunk_fun, after_fun)
   end
 
   defmacro chunk_while(callback, fun \\ nil) do
@@ -61,6 +71,7 @@ defmodule Stream.Reducers do
     quote do
       fn entry, acc(head, prev, tail) = acc ->
         value = unquote(callback).(entry)
+
         case prev do
           {:value, ^value} -> skip(acc)
           _ -> next_with_acc(unquote(fun), entry, head, {:value, value}, tail)
@@ -74,6 +85,7 @@ defmodule Stream.Reducers do
       fn
         _entry, acc(head, amount, tail) when amount > 0 ->
           skip(acc(head, amount - 1, tail))
+
         entry, acc(head, amount, tail) ->
           next_with_acc(unquote(fun), entry, head, amount, tail)
       end
@@ -85,6 +97,7 @@ defmodule Stream.Reducers do
       fn
         entry, acc(head, curr, tail) when curr in [unquote(nth), :first] ->
           skip(acc(head, 1, tail))
+
         entry, acc(head, curr, tail) ->
           next_with_acc(unquote(fun), entry, head, curr + 1, tail)
       end
@@ -140,6 +153,7 @@ defmodule Stream.Reducers do
       fn
         entry, acc(head, curr, tail) when curr in [unquote(nth), :first] ->
           next_with_acc(unquote(fun), unquote(mapper).(entry), head, 1, tail)
+
         entry, acc(head, curr, tail) ->
           next_with_acc(unquote(fun), entry, head, curr + 1, tail)
       end
@@ -163,6 +177,7 @@ defmodule Stream.Reducers do
       fn
         entry, acc(head, :first, tail) ->
           next_with_acc(unquote(fun), entry, head, {:ok, entry}, tail)
+
         entry, acc(head, {:ok, acc}, tail) ->
           value = unquote(callback).(entry, acc)
           next_with_acc(unquote(fun), value, head, {:ok, value}, tail)
@@ -185,9 +200,11 @@ defmodule Stream.Reducers do
         case curr do
           0 ->
             {:halt, original}
+
           1 ->
             {_, acc} = next_with_acc(unquote(fun), entry, head, 0, tail)
             {:halt, acc}
+
           _ ->
             next_with_acc(unquote(fun), entry, head, curr - 1, tail)
         end
@@ -200,6 +217,7 @@ defmodule Stream.Reducers do
       fn
         entry, acc(head, curr, tail) when curr in [unquote(nth), :first] ->
           next_with_acc(unquote(fun), entry, head, 1, tail)
+
         entry, acc(head, curr, tail) ->
           skip(acc(head, curr + 1, tail))
       end
@@ -222,6 +240,7 @@ defmodule Stream.Reducers do
     quote do
       fn entry, acc(head, prev, tail) = original ->
         value = unquote(callback).(entry)
+
         if Map.has_key?(prev, value) do
           skip(original)
         else