def __init__(self, client, resource, options=None):
        self._client = client
        self._resource = resource
        self._options = options

        self._websocket = None
        self._callback = None
        self._response_callbacks = []
        self._close_callbacks = []

        self._closing = threading.Lock()
        self._closed = False
        """True if this manager has already been closed."""

        self._request_counter = 0
        self._request_counter_lock = threading.Lock()

        # Thread created in ``.open()``
        self._consumer = None
def __init__ ( self , client , resource , options = None ) : self . _client = client self . _resource = resource self . _options = options self . _websocket = None self . _callback = None self . _response_callbacks = [ ] self . _close_callbacks = [ ] self . _closing = threading . Lock ( ) self . _closed = False self . _request_counter = 0 self . _request_counter_lock = threading . Lock ( ) self . _consumer = None
True if this manager has already been closed.