Extract periodic timers concern

1 files changed, 1 insertions, 17 deletions

diff --git a/lib/action_cable/channel/base.rb b/lib/action_cable/channel/base.rb
index fc229c9f27..ee22db4e09 100644
--- a/lib/action_cable/channel/base.rb
+++ b/lib/action_cable/channel/base.rb
@@ -2,14 +2,12 @@ module ActionCable
   module Channel
     class Base
       include Callbacks
+      include PeriodicTimers
       include Streams
 
       on_subscribe   :connect
       on_unsubscribe :disconnect
 
-      on_subscribe   :start_periodic_timers
-      on_unsubscribe :stop_periodic_timers
-
       attr_reader :params, :connection
       delegate :logger, to: :connection
 
@@ -22,7 +20,6 @@ module ActionCable
       def initialize(connection, channel_identifier, params = {})
         @connection = connection
         @channel_identifier = channel_identifier
-        @_active_periodic_timers = []
         @params = params
 
         perform_connection
@@ -115,19 +112,6 @@ module ActionCable
         end
 
 
-        def start_periodic_timers
-          self.class.periodic_timers.each do |callback, options|
-            @_active_periodic_timers << EventMachine::PeriodicTimer.new(options[:every]) do
-              worker_pool.async.run_periodic_timer(self, callback)
-            end
-          end
-        end
-
-        def stop_periodic_timers
-          @_active_periodic_timers.each { |timer| timer.cancel }
-        end
-
-
         def worker_pool
           connection.worker_pool
         end