diff options
| author | David Heinemeier Hansson <david@loudthinking.com> | 2015-06-19 22:43:39 +0200 |
|---|---|---|
| committer | David Heinemeier Hansson <david@loudthinking.com> | 2015-06-19 22:43:39 +0200 |
| commit | 51bd331004dd9fe4ae251345bf3a5e8ebf0eff81 (patch) | |
| tree | c78e343af1734f4478ea0e355968f0e3cb9be732 /lib/action_cable/channel/base.rb | |
| parent | a083cf69ca28656991ccc9c718bdd9c054ae00fb (diff) | |
| download | rails-51bd331004dd9fe4ae251345bf3a5e8ebf0eff81.tar.gz rails-51bd331004dd9fe4ae251345bf3a5e8ebf0eff81.tar.bz2 rails-51bd331004dd9fe4ae251345bf3a5e8ebf0eff81.zip | |
Better spacing
Diffstat (limited to 'lib/action_cable/channel/base.rb')
| -rw-r--r-- | lib/action_cable/channel/base.rb | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/lib/action_cable/channel/base.rb b/lib/action_cable/channel/base.rb index 3de932858a..ec14e13dfa 100644 --- a/lib/action_cable/channel/base.rb +++ b/lib/action_cable/channel/base.rb @@ -93,6 +93,7 @@ module ActionCable self.class.on_unsubscribe_callbacks.each { |callback| send(callback) } end + def start_periodic_timers self.class.periodic_timers.each do |callback, options| @_active_periodic_timers << EventMachine::PeriodicTimer.new(options[:every]) do @@ -105,6 +106,7 @@ module ActionCable @_active_periodic_timers.each {|t| t.cancel } end + def worker_pool connection.worker_pool end |