class TestServer

Attributes

config[R]
logger[R]
mutex[R]

Public Class Methods

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

  @config = OpenStruct.new(log_tags: [], subscription_adapter: subscription_adapter)

  @mutex = Monitor.new
end

Public Instance Methods

event_loop() click to toggle source
# File actioncable/test/stubs/test_server.rb, line 23
def event_loop
  @event_loop ||= ActionCable::Connection::StreamEventLoop.new.tap do |loop|
    loop.instance_variable_set(:@executor, Concurrent.global_io_executor)
  end
end
pubsub() click to toggle source
# File actioncable/test/stubs/test_server.rb, line 19
def pubsub
  @pubsub ||= @config.subscription_adapter.new(self)
end
worker_pool() click to toggle source
# File actioncable/test/stubs/test_server.rb, line 29
def worker_pool
  @worker_pool ||= ActionCable::Server::Worker.new(max_size: 5)
end