blob: 85d4892e4cfd0fbcdbb750fe54661053c09e3741 (
plain) (
tree)
|
|
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
|