class Faultline::AsyncSender

Public Class Methods

new(config) click to toggle source
# 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