Method: Atatus::Transport::Base#initialize

Defined in:
lib/atatus/transport/base.rb

#initialize(config) ⇒ Base

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Returns a new instance of Base.



41
42
43
44
45
46
47
48
49
50
51
52
 
# File 'lib/atatus/transport/base.rb', line 41

def initialize(config)
  @config = config
  @queue = SizedQueue.new(config.api_buffer_size)

  @serializers = Serializers.new(config)
  @filters = Filters.new(config)

  @stopped = Concurrent::AtomicBoolean.new
  @workers = Array.new(config.pool_size)

  @worker_mutex = Mutex.new
end