def __init__(self, connstr=None, **kwargs):
        """
        Bucket subclass for Twisted. This inherits from the 'AsyncBucket' class,
        but also adds some twisted-specific logic for hooking on a connection.
        """
        if connstr and 'connstr' not in kwargs:
            kwargs['connstr'] = connstr
        iops = v0Iops(reactor)
        super(RawBucket, self).__init__(iops=iops, **kwargs)

        self._evq = {
            'connect': ConnectionEventQueue(),
            '_dtor': TxEventQueue()
        }

        self._conncb = self._evq['connect']
        self._dtorcb = self._evq['_dtor']
dataset/ETHPy150Open couchbase/couchbase-python-client/txcouchbase/bucket.py/RawBucket.__init__/original