code: def StreamingShell(self, command, timeout_ms=None):
          
          return self.protocol_handler.StreamingCommand(
              self._handle, service=b'shell', command=command,
              timeout_ms=timeout_ms)
docs: Run command on the device, yielding each line of output.
  
          Args:
            command: Command to run on the target.
            timeout_ms: Maximum time to allow the command to run.
  
          Yields:
            The responses from the shell command.