class ActionCable::SubscriptionAdapter::Inline

def broadcast(channel, payload)
  subscriber_map.broadcast(channel, payload)
end

def initialize(*)
  super
  @subscriber_map = nil
end

def new_subscriber_map
  SubscriberMap.new
end

def shutdown
  # nothing to do
end

def subscribe(channel, callback, success_callback = nil)
  subscriber_map.add_subscriber(channel, callback, success_callback)
end

def subscriber_map
  @subscriber_map || @server.mutex.synchronize { @subscriber_map ||= new_subscriber_map }
end

def unsubscribe(channel, callback)
  subscriber_map.remove_subscriber(channel, callback)
end