diff options
| author | Javan Makhmali <javan@javan.us> | 2016-03-03 21:44:11 -0500 |
|---|---|---|
| committer | Javan Makhmali <javan@javan.us> | 2016-03-03 21:44:11 -0500 |
| commit | 3e4ecbe8e6afda1f96e1e474189a09aa8d19a0a7 (patch) | |
| tree | 113c57b3fc35cd0c325e291bdcefb782d00bad23 /actioncable/app | |
| parent | f1c93ed82802776c1be94fd8488257acaa253bd7 (diff) | |
| download | rails-3e4ecbe8e6afda1f96e1e474189a09aa8d19a0a7.tar.gz rails-3e4ecbe8e6afda1f96e1e474189a09aa8d19a0a7.tar.bz2 rails-3e4ecbe8e6afda1f96e1e474189a09aa8d19a0a7.zip | |
Store reference to Subscriptions instance for convenience
Diffstat (limited to 'actioncable/app')
| -rw-r--r-- | actioncable/app/assets/javascripts/action_cable/connection.coffee | 11 |
1 files changed, 6 insertions, 5 deletions
diff --git a/actioncable/app/assets/javascripts/action_cable/connection.coffee b/actioncable/app/assets/javascripts/action_cable/connection.coffee index bd63f5bb57..92272cc5b8 100644 --- a/actioncable/app/assets/javascripts/action_cable/connection.coffee +++ b/actioncable/app/assets/javascripts/action_cable/connection.coffee @@ -8,6 +8,7 @@ class ActionCable.Connection @reopenDelay: 500 constructor: (@consumer) -> + {@subscriptions} = @consumer @monitor = new ActionCable.ConnectionMonitor this send: (data) -> @@ -80,16 +81,16 @@ class ActionCable.Connection when message_types.ping @monitor.recordPing() when message_types.confirmation - @consumer.subscriptions.notify(identifier, "connected") + @subscriptions.notify(identifier, "connected") when message_types.rejection - @consumer.subscriptions.reject(identifier) + @subscriptions.reject(identifier) else - @consumer.subscriptions.notify(identifier, "received", message) + @subscriptions.notify(identifier, "received", message) open: -> ActionCable.log("WebSocket onopen event") @disconnected = false - @consumer.subscriptions.reload() + @subscriptions.reload() close: -> ActionCable.log("WebSocket onclose event") @@ -102,5 +103,5 @@ class ActionCable.Connection disconnect: -> return if @disconnected @disconnected = true - @consumer.subscriptions.notifyAll("disconnected") + @subscriptions.notifyAll("disconnected") @monitor.recordDisconnect() |