79 80 81 82 83 84 85
# File 'lib/uc/mqueue.rb', line 79 def clear nb_reader do |mq| loop { mq.receive } end rescue Errno::EAGAIN return end