From 5858bf3bec7d72361116e84d9bcde5daa5195ea2 Mon Sep 17 00:00:00 2001 From: Pratik Naik Date: Fri, 9 Oct 2015 09:09:24 -0500 Subject: Better schedule pubsub subscribe --- lib/action_cable/channel/streams.rb | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'lib/action_cable/channel/streams.rb') diff --git a/lib/action_cable/channel/streams.rb b/lib/action_cable/channel/streams.rb index 2d1506ee98..9fffdf1789 100644 --- a/lib/action_cable/channel/streams.rb +++ b/lib/action_cable/channel/streams.rb @@ -72,7 +72,7 @@ module ActionCable callback ||= default_stream_callback(broadcasting) streams << [ broadcasting, callback ] - pubsub.subscribe broadcasting, &callback + EM.next_tick { pubsub.subscribe broadcasting, &callback } logger.info "#{self.class.name} is streaming from #{broadcasting}" end -- cgit v1.2.3