blob: 85d4892e4cfd0fbcdbb750fe54661053c09e3741 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
|
require 'action_cable/subscription_adapter/inline'
module ActionCable
module SubscriptionAdapter
class Async < Inline # :nodoc:
private
def subscriber_map
@subscriber_map ||= AsyncSubscriberMap.new
end
class AsyncSubscriberMap < SubscriberMap
def add_subscriber(*)
::EM.next_tick { super }
end
def invoke_callback(*)
::EM.next_tick { super }
end
end
end
end
end
|