diff options
| author | Lachlan Sylvester <lachlan.sylvester@publicisfrontfoot.com.au> | 2015-08-10 16:50:52 +1000 |
|---|---|---|
| committer | Lachlan Sylvester <lachlan.sylvester@publicisfrontfoot.com.au> | 2015-08-11 09:12:53 +1000 |
| commit | 8fcdfc31c88b33529893c97ace8544200e4a231c (patch) | |
| tree | 4bc3b60b14139d1771dd0a5ea0293e0aeeef8135 /lib/action_cable/channel/streams.rb | |
| parent | edbef56c1fb3607315647c6115ec07d1e4e86ca0 (diff) | |
| download | rails-8fcdfc31c88b33529893c97ace8544200e4a231c.tar.gz rails-8fcdfc31c88b33529893c97ace8544200e4a231c.tar.bz2 rails-8fcdfc31c88b33529893c97ace8544200e4a231c.zip | |
Clear out the streams when they are stopped. Otherwise we will keep trying to stop them.
Diffstat (limited to 'lib/action_cable/channel/streams.rb')
| -rw-r--r-- | lib/action_cable/channel/streams.rb | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/lib/action_cable/channel/streams.rb b/lib/action_cable/channel/streams.rb index a37194b884..2d1506ee98 100644 --- a/lib/action_cable/channel/streams.rb +++ b/lib/action_cable/channel/streams.rb @@ -88,7 +88,7 @@ module ActionCable streams.each do |broadcasting, callback| pubsub.unsubscribe_proc broadcasting, callback logger.info "#{self.class.name} stopped streaming from #{broadcasting}" - end + end.clear end private |