class Gem::StreamUI::ThreadedDownloadReporter

def locked_puts(message)
  MUTEX.synchronize do
    @out.puts message
  end
end