# File lib/ruote/log/test_logger.rb, line 129 def check_msg (msg) wakeup = [] @waiting.each do |thread, interests| wakeup << thread if matches(interests, msg) end @waiting.delete_if { |t, i| i.size < 1 } wakeup.each do |thread| thread['__result__'] = msg thread.wakeup end end