diff options
| author | David Heinemeier Hansson <david@loudthinking.com> | 2015-06-21 21:34:04 +0200 |
|---|---|---|
| committer | David Heinemeier Hansson <david@loudthinking.com> | 2015-06-21 21:34:04 +0200 |
| commit | 22b9882ea6ab621ac5deceb700ec503f796812e6 (patch) | |
| tree | 6aedbe9907999eca5584a7fc1642697b6e0a7f24 /lib/action_cable/connection/base.rb | |
| parent | 81ae9ee32162ececbd70664b2821e7c636eaed8b (diff) | |
| download | rails-22b9882ea6ab621ac5deceb700ec503f796812e6.tar.gz rails-22b9882ea6ab621ac5deceb700ec503f796812e6.tar.bz2 rails-22b9882ea6ab621ac5deceb700ec503f796812e6.zip | |
Styling
Diffstat (limited to 'lib/action_cable/connection/base.rb')
| -rw-r--r-- | lib/action_cable/connection/base.rb | 13 |
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) |