   defp exit(info, mfa, log_reason, reason) do
     {fun, args} = get_running(mfa)
 
-    :error_logger.format(
+    message =
       '** Task ~p terminating~n' ++
-      '** Started from ~p~n' ++
-      '** When function  == ~p~n' ++
-      '**      arguments == ~p~n' ++
-      '** Reason for termination == ~n' ++
-      '** ~p~n', [self(), get_from(info), fun, args, get_reason(log_reason)])
+        '** Started from ~p~n' ++
+        '** When function  == ~p~n' ++
+        '**      arguments == ~p~n' ++ '** Reason for termination == ~n' ++ '** ~p~n'
+
+    :error_logger.format(message, [self(), get_from(info), fun, args, get_reason(log_reason)])
 
     exit(reason)
   end

  defp unlink_and_kill(pid) do
    caller = self()
    ref = make_ref()
    enforcer = spawn(fn ->
      mon = Process.monitor(caller)
      receive do
        {:done, ^ref} -> :ok
        {:DOWN, ^mon, _, _, _} -> Process.exit(pid, :kill)
      end
    end)
    Process.unlink(pid)
    Process.exit(pid, :kill)
    send(enforcer, {:done, ref})

          reducer.(reply, acc)
        catch
          kind, reason ->
            stacktrace = System.stacktrace()
            is_function(next) && next.({:halt, []})
            stream_close(monitor_pid, monitor_ref, timeout)
            :erlang.raise(kind, reason, stacktrace)
        else
          pair ->
            stream_deliver(
              pair,
              max,
              spawned,
              delivered + 1,
              Map.delete(waiting, delivered),
              next,
              config
            )
        end

      %{} ->
        stream_reduce({:cont, acc}, max, spawned, delivered, waiting, next, config)
    end
