lib/action_cable/worker.rb


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

module ActionCable
  class Worker
    include ActiveSupport::Callbacks
    include Celluloid

    define_callbacks :work

    def received_data(connection, data)
      run_callbacks :work do
        connection.received_data(data)
      end
    end

    def cleanup_subscriptions(connection)
      connection.cleanup_subscriptions
    end

  end
end