From 3e4ecbe8e6afda1f96e1e474189a09aa8d19a0a7 Mon Sep 17 00:00:00 2001
From: Javan Makhmali <javan@javan.us>
Date: Thu, 3 Mar 2016 21:44:11 -0500
Subject: Store reference to Subscriptions instance for convenience

---
 .../app/assets/javascripts/action_cable/connection.coffee     | 11 ++++++-----
 1 file changed, 6 insertions(+), 5 deletions(-)

(limited to 'actioncable/app')

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()
-- 
cgit v1.2.3