Class: StatsD::Instrument::BatchedUDPSink::Buffer

Inherits:
SizedQueue
  • Object
show all
Defined in:
lib/statsd/instrument/batched_udp_sink.rb

Instance Method Summary collapse

Instance Method Details

#inspect ⇒ Object 



72
73
74
 
# File 'lib/statsd/instrument/batched_udp_sink.rb', line 72

def inspect
  "<#{self.class.name}:#{object_id} capacity=#{max} size=#{size}>"
end

#pop_nonblock ⇒ Object 



76
77
78
79
80
 
# File 'lib/statsd/instrument/batched_udp_sink.rb', line 76

def pop_nonblock
  pop(true)
rescue ThreadError
  nil
end

#push_nonblock(item) ⇒ Object 



66
67
68
69
70
 
# File 'lib/statsd/instrument/batched_udp_sink.rb', line 66

def push_nonblock(item)
  push(item, true)
rescue ThreadError, ClosedQueueError
  nil
end