Method: Faultline::AsyncSender#initialize

Defined in:
lib/faultline/async_sender.rb

#initialize(config) ⇒ AsyncSender 



3
4
5
6
7
8
9
10
11
 
# File 'lib/faultline/async_sender.rb', line 3

def initialize(config)
  @config = config
  @unsent = SizedQueue.new(config.queue_size)
  @sender = SyncSender.new(config)
  @closed = false
  @workers = ThreadGroup.new
  @mutex = Mutex.new
  @pid = nil
end