   defp stream_reduce({:cont, acc}, max, spawned, delivered, waiting, next, config)
        when max == 0
        when next == :done do
-    %{monitor_pid: monitor_pid, monitor_ref: monitor_ref,
-      timeout: timeout, on_timeout: on_timeout, ordered: ordered?} = config
+    %{
+      monitor_pid: monitor_pid,
+      monitor_ref: monitor_ref,
+      timeout: timeout,
+      on_timeout: on_timeout,
+      ordered: ordered?
+    } = config
 
     receive do
       # The task at position "position" replied with "value". We put the

  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})

      :error, value ->
        reason = {value, System.stacktrace()}
        exit(info, mfa, reason, reason)

      :throw, value ->
        reason = {{:nocatch, value}, System.stacktrace()}
        exit(info, mfa, reason, reason)

      :exit, value ->
        exit(info, mfa, {value, System.stacktrace()}, value)
    end
