class Concurrent::BlockingRingBuffer

def count

Returns:
  • (Integer) - the number of elements currently in the buffer 
def count
  @mutex.synchronize { @buffer.count }
end