gistfile1.txt

defmodule ChannelHandler do
  def process_plugs(plugs, socket, payload, bindings \\ %{}) do
    result =
			Enum.reduce_while(plugs, {socket, payload, bindings},
				fn plug, {socket, payload, bindings} ->
	        case process_plug(plug, socket, payload, bindings) do
	          {:cont, socket, payload, bindings} -> {:cont, {:cont, socket, payload, bindings}}
	          {:halt, socket, status, reason} -> {:halt, {:halt, socket, status, reason}}
	        end
	    end)

		case result do
      {:cont, socket, payload, bindings} ->
				{:cont, socket, payload, bindings}
      {:halt, status, reason, socket} ->
				{:reply, {status, reason}, socket}
    end
  end

  defp process_plug(plug, socket, payload, bindings) when is_function(plug) do
    process_plug({plug, []}, socket, payload, bindings)
  end

  defp process_plug({plug, opts}, socket, payload, bindings) do
    plug.(socket, payload, bindings, opts)
  end
end