Class TestServer < Object

# File actioncable/test/stubs/test_server.rb, line 9
def initialize(subscription_adapter: SuccessAdapter)
  @logger = ActiveSupport::TaggedLogging.new ActiveSupport::Logger.new(StringIO.new)

  @config = OpenStruct.new(log_tags: [], subscription_adapter: subscription_adapter)
  @config.use_faye = ENV['FAYE'].present?
  @config.client_socket_class = if @config.use_faye
                                  ActionCable::Connection::FayeClientSocket
                                else
                                  ActionCable::Connection::ClientSocket
                                end

   @mutex = Monitor.new
end

# File actioncable/test/stubs/test_server.rb, line 27
def event_loop
  @event_loop ||= if @config.use_faye
                    ActionCable::Connection::FayeEventLoop.new
                  else
                    ActionCable::Connection::StreamEventLoop.new
                  end
end

# File actioncable/test/stubs/test_server.rb, line 23
def pubsub
  @pubsub ||= @config.subscription_adapter.new(self)
end

# File actioncable/test/stubs/test_server.rb, line 35
def worker_pool
  @worker_pool ||= ActionCable::Server::Worker.new(max_size: 5)
end