Sha256: 38861ec5f9b08c83f44a3fb1d2868214ced45ca4943dec49487797124eaa210d
Contents?: true
Size: 584 Bytes
Versions: 18
Compression:
Stored size: 584 Bytes
Contents
# frozen_string_literal: true
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
18 entries across 18 versions & 4 rubygems