Sha256: 52605bc09fddf1f45e309f9e381a6c03f60a9a89d7bb288a5e8c591315958d31
Contents?: true
Size: 605 Bytes
Versions: 31
Compression:
Stored size: 605 Bytes
Contents
require 'action_cable/subscription_adapter/inline'
module ActionCable
module SubscriptionAdapter
class Async < Inline # :nodoc:
private
def new_subscriber_map
AsyncSubscriberMap.new(server.event_loop)
end
class AsyncSubscriberMap < SubscriberMap
def initialize(event_loop)
@event_loop = event_loop
super()
end
def add_subscriber(*)
@event_loop.post { super }
end
def invoke_callback(*)
@event_loop.post { super }
end
end
end
end
end
Version data entries
31 entries across 31 versions & 4 rubygems