def close(self, timeout_ms):
    """Close this stream, future reads/writes will fail."""
    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)
Close this stream, future reads/writes will fail.