aboutsummaryrefslogtreecommitdiffstats
path: root/lib/action_cable
diff options
context:
space:
mode:
authorDavid Heinemeier Hansson <david@loudthinking.com>2015-02-09 21:22:21 -0800
committerDavid Heinemeier Hansson <david@loudthinking.com>2015-02-09 21:22:21 -0800
commit9b8195b4b03e9ee70bde3072e364826f198d9fb2 (patch)
treeb60dc72c85390d1fc2d2cc2e7bf700dc1025ee8a /lib/action_cable
parent85ac703585a3bc413571e23d2e7dc3ca1e4cad2e (diff)
downloadrails-9b8195b4b03e9ee70bde3072e364826f198d9fb2.tar.gz
rails-9b8195b4b03e9ee70bde3072e364826f198d9fb2.tar.bz2
rails-9b8195b4b03e9ee70bde3072e364826f198d9fb2.zip
Inline id_key variable
Diffstat (limited to 'lib/action_cable')
-rw-r--r--lib/action_cable/server.rb11
1 files changed, 4 insertions, 7 deletions
diff --git a/lib/action_cable/server.rb b/lib/action_cable/server.rb
index e657f6d636..96d21416bf 100644
--- a/lib/action_cable/server.rb
+++ b/lib/action_cable/server.rb
@@ -88,17 +88,14 @@ module ActionCable
end
def process_message(message)
- id_key = message['identifier']
-
- if @subscriptions[id_key]
- @subscriptions[id_key].receive(ActiveSupport::JSON.decode message['data'])
+ if @subscriptions[message['identifier']]
+ @subscriptions[message['identifier']].receive(ActiveSupport::JSON.decode message['data'])
end
end
def unsubscribe_channel(data)
- id_key = data['identifier']
- @subscriptions[id_key].unsubscribe
- @subscriptions.delete(id_key)
+ @subscriptions[data['identifier']].unsubscribe
+ @subscriptions.delete(data['identifier'])
end
def invalid_request