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)
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 )
Close this stream, future reads/writes will fail.