aboutsummaryrefslogtreecommitdiffstats
path: root/lib/action_cable/connection/base.rb
diff options
context:
space:
mode:
authorDavid Heinemeier Hansson <david@loudthinking.com>2015-06-20 16:22:40 +0200
committerDavid Heinemeier Hansson <david@loudthinking.com>2015-06-20 16:22:40 +0200
commit294a277a8409e05c6b98cd8e46a8e0745f68b40d (patch)
tree093decd716e80cfc208f31dae55aa9935fe572fa /lib/action_cable/connection/base.rb
parent404867d332069d8b87547e1eae5ed1d0a7a1b95c (diff)
downloadrails-294a277a8409e05c6b98cd8e46a8e0745f68b40d.tar.gz
rails-294a277a8409e05c6b98cd8e46a8e0745f68b40d.tar.bz2
rails-294a277a8409e05c6b98cd8e46a8e0745f68b40d.zip
Rename broadcast to transmit for the connection/channel->subscriber communication
Disambiguate it from the broadcast to channel method used by the broadcaster (which actually has several listeners, whereas a connection/channel instance only ever has one listener – hence not much of a BROADcast).
Diffstat (limited to 'lib/action_cable/connection/base.rb')
-rw-r--r--lib/action_cable/connection/base.rb10
1 files changed, 5 insertions, 5 deletions
diff --git a/lib/action_cable/connection/base.rb b/lib/action_cable/connection/base.rb
index d6e5bfa2d2..52f94a7ab0 100644
--- a/lib/action_cable/connection/base.rb
+++ b/lib/action_cable/connection/base.rb
@@ -34,8 +34,8 @@ module ActionCable
@websocket = Faye::WebSocket.new(@env)
@websocket.on(:open) do |event|
- broadcast_ping_timestamp
- @ping_timer = EventMachine.add_periodic_timer(PING_INTERVAL) { broadcast_ping_timestamp }
+ transmit_ping_timestamp
+ @ping_timer = EventMachine.add_periodic_timer(PING_INTERVAL) { transmit_ping_timestamp }
worker_pool.async.invoke(self, :initialize_connection)
end
@@ -87,7 +87,7 @@ module ActionCable
end
end
- def broadcast(data)
+ def transmit(data)
@websocket.send data
end
@@ -127,8 +127,8 @@ module ActionCable
disconnect if respond_to?(:disconnect)
end
- def broadcast_ping_timestamp
- broadcast({ identifier: '_ping', message: Time.now.to_i }.to_json)
+ def transmit_ping_timestamp
+ transmit({ identifier: '_ping', message: Time.now.to_i }.to_json)
end
def subscribe_channel(data)