code: def _check_remote_command(self, destination, timeout_ms, success_msgs=None):
      
      timeout = timeouts.PolledTimeout.from_millis(timeout_ms)
      stream = self._adb_connection.open_stream(destination, timeout)
      if not stream:
        raise usb_exceptions.AdbStreamUnavailableError(
            'Service %s not supported', destination)
      try:
        message = stream.read(timeout_ms=timeout)
        # Some commands report success messages, ignore them.
        if any([m in message for m in success_msgs]):
          return
      except usb_exceptions.CommonUsbError:
        if destination.startswith('reboot:'):
          # We expect this if the device is rebooting.
          return
        raise
      raise usb_exceptions.AdbRemoteError('Device message: %s', message)
docs: Open a stream to destination, check for remote errors.
  
      Used for reboot, remount, and root services.  If this method returns, the
      command was successful, otherwise an appropriate error will have been
      raised.
  
      Args:
        destination: Stream destination to open.
        timeout_ms: Timeout in milliseconds for the operation.
        success_msgs: If provided, a list of messages that, if returned from the
          device, indicate success, so don't treat them as errors.
  
      Raises:
        AdbRemoteError: If the remote command fails, will contain any message we
          got back from the device.
        AdbStreamUnavailableError: The service requested isn't supported.