diff options
| author | Pratik Naik <pratiknaik@gmail.com> | 2015-10-20 17:17:18 -0500 |
|---|---|---|
| committer | Pratik Naik <pratiknaik@gmail.com> | 2015-10-21 13:47:48 -0500 |
| commit | 0ce0cf0c04b53ee6c7038d8912dd1ed433f7935f (patch) | |
| tree | 152c3ba76fbdfab6342af72b525d9eac7d7363ac /lib/action_cable/connection/subscriptions.rb | |
| parent | 904b83b9c3d5dc1f1ceac1552dd5b80513aa3232 (diff) | |
| download | rails-0ce0cf0c04b53ee6c7038d8912dd1ed433f7935f.tar.gz rails-0ce0cf0c04b53ee6c7038d8912dd1ed433f7935f.tar.bz2 rails-0ce0cf0c04b53ee6c7038d8912dd1ed433f7935f.zip | |
Allow rejecting subscriptions from the channel
Diffstat (limited to 'lib/action_cable/connection/subscriptions.rb')
| -rw-r--r-- | lib/action_cable/connection/subscriptions.rb | 8 |
1 files changed, 6 insertions, 2 deletions
diff --git a/lib/action_cable/connection/subscriptions.rb b/lib/action_cable/connection/subscriptions.rb index 229be2a316..6199db4898 100644 --- a/lib/action_cable/connection/subscriptions.rb +++ b/lib/action_cable/connection/subscriptions.rb @@ -37,8 +37,12 @@ module ActionCable def remove(data) logger.info "Unsubscribing from channel: #{data['identifier']}" - subscriptions[data['identifier']].unsubscribe_from_channel - subscriptions.delete(data['identifier']) + remove_subscription subscriptions[data['identifier']] + end + + def remove_subscription(subscription) + subscription.unsubscribe_from_channel + subscriptions.delete(subscription.identifier) end def perform_action(data) |