code: def _read_stdout(self):
          '''Continuously read the stdout for messages.'''
          try:
              while self._process.returncode is None:
                  line = yield from self._process.stdout.readline()
  
                  _logger.debug('Read stdout line %s', repr(line))
  
                  if not line:
                      break
  
                  if self._stdout_callback:
                      yield from self._stdout_callback(line)
  
          except Exception:
              _logger.exception('Unhandled read stdout exception.')
              raisf _read_stdout(self):
          '''Continuously read the stdout for messages.'''
          try:
              while self._process.returncode is None:
                  line = yield from self._process.stdout.readline()
  
                  _logger.debug('Read stdout line %s', repr(line))
  
                  if not line:
                      break
  
                  if self._stdout_callback:
                      yield from self._stdout_callback(line)
  
          except Exception:
              _logger.exception('Unhandled read stdout exception.')
              raise
docs: Continuously read the stdout for messages.