aboutsummaryrefslogtreecommitdiffstats
path: root/lib/action_cable/connection/base.rb
diff options
context:
space:
mode:
Diffstat (limited to 'lib/action_cable/connection/base.rb')
-rw-r--r--lib/action_cable/connection/base.rb13
1 files changed, 8 insertions, 5 deletions
diff --git a/lib/action_cable/connection/base.rb b/lib/action_cable/connection/base.rb
index 0d666713d2..175b596241 100644
--- a/lib/action_cable/connection/base.rb
+++ b/lib/action_cable/connection/base.rb
@@ -5,17 +5,20 @@ module ActionCable
include InternalChannel
PING_INTERVAL = 3
-
- attr_reader :env, :server, :logger
+
+ attr_reader :server, :env
delegate :worker_pool, :pubsub, to: :server
+ attr_reader :logger
+
def initialize(server, env)
@started_at = Time.now
- @server = server
- @env = env
- @accept_messages = false
+ @server, @env = server, env
+
+ @accept_messages = false
@pending_messages = []
+
@subscriptions = {}
@logger = TaggedLoggerProxy.new(server.logger, tags: log_tags)