aboutsummaryrefslogblamecommitdiffstats
path: root/actioncable/test/stubs/test_server.rb
blob: 5bf2a151dc6c55850d2a29cc78a6a021b4d7d97f (plain) (tree)
1
2
3
4
5
6
7
8
9
                 

                
                                          
                                           
 
                                      
 
                                                      
                                                                                      

                                                                                      
 
                        

     
            
                                                      
     
 
                

                                                                              
       
     



                                                                 
   
require "ostruct"

class TestServer
  include ActionCable::Server::Connections
  include ActionCable::Server::Broadcasting

  attr_reader :logger, :config, :mutex

  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

  def pubsub
    @pubsub ||= @config.subscription_adapter.new(self)
  end

  def event_loop
    @event_loop ||= ActionCable::Connection::StreamEventLoop.new.tap do |loop|
      loop.instance_variable_set(:@executor, Concurrent.global_io_executor)
    end
  end

  def worker_pool
    @worker_pool ||= ActionCable::Server::Worker.new(max_size: 5)
  end
end