

def __init__(self, connstr=None, **kwargs):
    "\n        Bucket subclass for Twisted. This inherits from the 'AsyncBucket' class,\n        but also adds some twisted-specific logic for hooking on a connection.\n        "
    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