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