diff options
Diffstat (limited to 'lib/action_cable/worker.rb')
-rw-r--r-- | lib/action_cable/worker.rb | 10 |
1 files changed, 2 insertions, 8 deletions
diff --git a/lib/action_cable/worker.rb b/lib/action_cable/worker.rb index 1a8bee974b..6687af43a0 100644 --- a/lib/action_cable/worker.rb +++ b/lib/action_cable/worker.rb @@ -5,15 +5,9 @@ module ActionCable define_callbacks :work - def received_data(connection, data) + def invoke(receiver, method, *args) run_callbacks :work do - connection.received_data(data) - end - end - - def cleanup_subscriptions(connection) - run_callbacks :work do - connection.cleanup_subscriptions + receiver.send method, *args end end |