code: def close(self, timeout_ms):
      
      if self.closed_state == self.ClosedState.CLOSED:
        return
  
      self.closed_state = self.ClosedState.CLOSED
      try:
        if not self.adb_connection.close_stream_transport(
            self, timeouts.PolledTimeout.from_millis(timeout_ms)):
          _LOG.warning('Attempt to close mystery %s', self)
      except usb_exceptions.AdbTimeoutError:
        _LOG.warning('%s close() timed out, ignoring', self)
docs: Close this stream, future reads/writes will fail.