

def n1qlQueryEx(self, cls, *args, **kwargs):
    '\n        Execute a N1QL statement providing a custom handler for rows.\n\n        This method allows you to define your own subclass (of\n        :class:`~AsyncN1QLRequest`) which can handle rows as they are\n        received from the network.\n\n        :param cls: The subclass (not instance) to use\n        :param args: Positional arguments for the class constructor\n        :param kwargs: Keyword arguments for the class constructor\n\n        .. seealso:: :meth:`queryEx`, around which this method wraps\n        '
    kwargs['itercls'] = cls
    o = super(AsyncBucket, cls).n1ql_query(*args, **kwargs)
    if (not self.connected):
        self.connect().addCallback((lambda x: o.start()))
    else:
        o.start()
    return o

dataset/ETHPy150Open couchbase/couchbase-python-client/txcouchbase/bucket.py RawBucket.n1qlQueryEx/VarMisuse@33/222 `self`->`cls`