aboutsummaryrefslogblamecommitdiffstats
path: root/lib/action_cable/worker.rb
blob: 6687af43a0a4ebf473ef853620d2a6f0a09bd9f4 (plain) (tree)
1
2
3
4
5
6
7
8
9






                                    
                                       
                            
                                   






                                                                                               



       
module ActionCable
  class Worker
    include ActiveSupport::Callbacks
    include Celluloid

    define_callbacks :work

    def invoke(receiver, method, *args)
      run_callbacks :work do
        receiver.send method, *args
      end
    end

    def run_periodic_timer(channel, callback)
      run_callbacks :work do
        callback.respond_to?(:call) ? channel.instance_exec(&callback) : channel.send(callback)
      end
    end

  end
end