diff options
| author | palkan <dementiev.vm@gmail.com> | 2016-09-21 02:57:10 +0300 |
|---|---|---|
| committer | palkan <dementiev.vm@gmail.com> | 2016-09-22 20:25:09 +0300 |
| commit | 3e68d8b872b48ecb45268a7e5fcb937e68f2724f (patch) | |
| tree | 6c1a25c42a8baea1141af95016abbce1f7d78469 /actioncable/lib/action_cable/channel/streams.rb | |
| parent | 03a209e92aeed1e724b3ff787ec77936b7163ca5 (diff) | |
| download | rails-3e68d8b872b48ecb45268a7e5fcb937e68f2724f.tar.gz rails-3e68d8b872b48ecb45268a7e5fcb937e68f2724f.tar.bz2 rails-3e68d8b872b48ecb45268a7e5fcb937e68f2724f.zip | |
Add Channel#ensure_confirmation_sent; call #subscribe_to_channel after initializing
Diffstat (limited to 'actioncable/lib/action_cable/channel/streams.rb')
| -rw-r--r-- | actioncable/lib/action_cable/channel/streams.rb | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/actioncable/lib/action_cable/channel/streams.rb b/actioncable/lib/action_cable/channel/streams.rb index c9b58f3a04..e480b93df0 100644 --- a/actioncable/lib/action_cable/channel/streams.rb +++ b/actioncable/lib/action_cable/channel/streams.rb @@ -84,8 +84,7 @@ module ActionCable connection.server.event_loop.post do pubsub.subscribe(broadcasting, handler, lambda do - @defer_subscription_confirmation_counter.decrement - transmit_subscription_confirmation unless defer_subscription_confirmation? + ensure_confirmation_sent logger.info "#{self.class.name} is streaming from #{broadcasting}" end) end |