aboutsummaryrefslogtreecommitdiffstats
path: root/actioncable/lib/action_cable/channel/streams.rb
diff options
context:
space:
mode:
authorMatthew Draper <matthew@trebex.net>2016-01-24 15:51:21 +1030
committerMatthew Draper <matthew@trebex.net>2016-01-24 15:52:47 +1030
commite81bb80cb4214ff795f7a2bb03f699e2a7f7d45a (patch)
treec5a4cca8a8fb7f2129330e3b9bbc399886cccc03 /actioncable/lib/action_cable/channel/streams.rb
parentdccc15d4030f250f38987328b6201282c1ef34a5 (diff)
downloadrails-e81bb80cb4214ff795f7a2bb03f699e2a7f7d45a.tar.gz
rails-e81bb80cb4214ff795f7a2bb03f699e2a7f7d45a.tar.bz2
rails-e81bb80cb4214ff795f7a2bb03f699e2a7f7d45a.zip
Normalize on no arguments for the success callback
Diffstat (limited to 'actioncable/lib/action_cable/channel/streams.rb')
-rw-r--r--actioncable/lib/action_cable/channel/streams.rb2
1 files changed, 1 insertions, 1 deletions
diff --git a/actioncable/lib/action_cable/channel/streams.rb b/actioncable/lib/action_cable/channel/streams.rb
index 589946c3db..e2876ef6fa 100644
--- a/actioncable/lib/action_cable/channel/streams.rb
+++ b/actioncable/lib/action_cable/channel/streams.rb
@@ -76,7 +76,7 @@ module ActionCable
streams << [ broadcasting, callback ]
EM.next_tick do
- pubsub.subscribe(broadcasting, callback, lambda do |reply|
+ pubsub.subscribe(broadcasting, callback, lambda do
transmit_subscription_confirmation
logger.info "#{self.class.name} is streaming from #{broadcasting}"
end)