@classmethod
  def StreamingCommand(cls, usb, service, command='', timeout_ms=None):
    connection = cls.Open(usb, destination='%s:%s' % (service, command),
                          timeout_ms=timeout_ms)
    for data in connection.ReadUntilClose():
      yield data
One complete set of USB packets for a single command.
dataset/ETHPy150Open google/python-adb/adb/adb_protocol.py/AdbMessage.StreamingCommand