def queryEx(self, viewcls, *args, **kwargs):

        kwargs['itercls'] = viewcls
        o = super(AsyncBucket, self).query(*args, **kwargs)
        if not self.connected:
            self.connect().addCallback(lambda x: o.start())
        else:
            o.start()

        return o
Query a view, with the ``viewcls`` instance receiving events
dataset/ETHPy150Open couchbase/couchbase-python-client/txcouchbase/bucket.py/RawBucket.queryEx