From 6fc05cce827157080f37424325e0cf30091c35bc Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Troels=20Br=C3=B8dsgaard?= Date: Thu, 24 Sep 2015 21:30:01 +0200 Subject: [PATCH] change `sockets` to `channels` in Transport.dispatch --- lib/phoenix/socket/transport.ex | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/lib/phoenix/socket/transport.ex b/lib/phoenix/socket/transport.ex index ddea5a8ffc..25db53f4ee 100644 --- a/lib/phoenix/socket/transport.ex +++ b/lib/phoenix/socket/transport.ex @@ -191,14 +191,14 @@ defmodule Phoenix.Socket.Transport do must be sent as result """ - def dispatch(msg, sockets, socket) + def dispatch(msg, channels, socket) - def dispatch(%{ref: ref, topic: "phoenix", event: "heartbeat"}, _sockets, _socket) do + def dispatch(%{ref: ref, topic: "phoenix", event: "heartbeat"}, _channels, _socket) do {:reply, %Reply{ref: ref, topic: "phoenix", status: :ok, payload: %{}}} end - def dispatch(%Message{} = msg, sockets, socket) do - sockets + def dispatch(%Message{} = msg, channels, socket) do + channels |> HashDict.get(msg.topic) |> do_dispatch(msg, socket) end @@ -231,8 +231,8 @@ defmodule Phoenix.Socket.Transport do reply_ignore(msg, socket) end - defp do_dispatch(socket_pid, msg, _socket) do - send(socket_pid, msg) + defp do_dispatch(channel_pid, msg, _socket) do + send(channel_pid, msg) :noreply end