code: def _start_reader(self):
          
          while True:
              message = yield From(self.pipe.read_message())
              self._process(message)
docs: Read messages from the Win32 pipe server and handle them.