code: def write(self, message, flush=False):
          
          # this need be threadsafe because the concurrent spinning running on
          # the stderr
          with self.lock:
              self.paralell_stream.erase()
              super(Clean, self).write(message, flush)
docs: Write something on the default stream with a prefixed message