1
0
Fork 0
mirror of https://github.com/rails/rails.git synced 2022-11-09 12:12:34 -05:00
rails--rails/actioncable/test/stubs/test_server.rb

31 lines
783 B
Ruby
Raw Normal View History

require "ostruct"
2015-07-12 11:07:31 -04:00
class TestServer
2015-07-12 12:44:46 -04:00
include ActionCable::Server::Connections
include ActionCable::Server::Broadcasting
2015-07-12 12:44:46 -04:00
attr_reader :logger, :config, :mutex
2015-07-12 11:07:31 -04:00
def initialize(subscription_adapter: SuccessAdapter)
2015-07-12 11:07:31 -04:00
@logger = ActiveSupport::TaggedLogging.new ActiveSupport::Logger.new(StringIO.new)
@config = OpenStruct.new(log_tags: [], subscription_adapter: subscription_adapter)
@mutex = Monitor.new
2016-01-15 17:11:30 -05:00
end
def pubsub
@pubsub ||= @config.subscription_adapter.new(self)
2015-07-12 11:07:31 -04:00
end
2015-10-15 22:11:49 -04:00
def event_loop
@event_loop ||= ActionCable::Connection::StreamEventLoop.new.tap do |loop|
loop.instance_variable_set(:@executor, Concurrent.global_io_executor)
end
2015-10-15 22:11:49 -04:00
end
def worker_pool
@worker_pool ||= ActionCable::Server::Worker.new(max_size: 5)
end
2015-07-12 11:07:31 -04:00
end