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 



69
70
71
 
# File 'lib/statsd/instrument/batched_udp_sink.rb', line 69

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

#pop_nonblock ⇒ Object 



73
74
75
76
77
 
# File 'lib/statsd/instrument/batched_udp_sink.rb', line 73

def pop_nonblock
  pop(true)
rescue ThreadError
  nil
end

#push_nonblock(item) ⇒ Object 



63
64
65
66
67
 
# File 'lib/statsd/instrument/batched_udp_sink.rb', line 63

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