def n1qlQueryEx(self, cls, *args, **kwargs):
        kwargs['itercls'] = cls
        o = super(AsyncBucket, self).n1ql_query(*args, **kwargs)
        if not self.connected:
            self.connect().addCallback(lambda x: o.start())
        else:
            o.start()
        return o
Execute a N1QL statement providing a custom handler for rows.
dataset/ETHPy150Open couchbase/couchbase-python-client/txcouchbase/bucket.py/RawBucket.n1qlQueryEx