

def queryAll(self, *args, **kwargs):
    '\n        Returns a :class:`Deferred` object which will have its callback invoked\n        with a :class:`BatchedView` when the results are complete.\n\n        Parameters follow conventions of\n        :meth:`~couchbase.bucket.Bucket.query`.\n\n        Example::\n\n          d = cb.queryAll("beer", "brewery_beers")\n          def on_all_rows(rows):\n              for row in rows:\n                 print("Got row {0}".format(row))\n\n          d.addCallback(on_all_rows)\n\n        '
    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()

dataset/ETHPy150Open couchbase/couchbase-python-client/txcouchbase/bucket.py RawBucket.queryAll/original