def queryAll(self, *args, **kwargs):

        if not self.connected:
            cb = lambda x: self.queryAll(*args, **kwargs)
            return self.connect().addCallback(cb)

        kwargs['itercls'] = BatchedView
        o = super(RawBucket, self).query(*args, **kwargs)
        o.start()
        return o._getDeferred()
Returns a :class:`Deferred` object which will have its callback invoked
dataset/ETHPy150Open couchbase/couchbase-python-client/txcouchbase/bucket.py/RawBucket.queryAll