     :gen_server.start_link({:local, name}, __MODULE__, cache, [])
   end
 
-  defp write_from_cache(conn, cache, last_id) do
-    Enum.reduce(Cache.list(cache, last_id), conn, fn(item, conn) -> write(conn, item) end)
+  defp write_from_cache(transport, cache, last_id) do
+    Enum.reduce(Cache.list(cache, last_id), transport, fn(item, transport) -> write(transport, item) end)
   end
 
   defp message(id, item) do

  import Funnel.Transport, only: [write: 2]

  defmodule Funnel.TransistorState do
    defstruct cache: nil, connections: []
  end

  alias Funnel.TransistorState

defmodule Funnel.Transistor do
  @moduledoc """
  `Funnel.Transistor` can be see as a User. It can have several transports, and
  will notify a matching document on each of thoses transports.
  """
  use GenServer.Behaviour
  alias Funnel.Transistor.Cache
