Method __init__

acouchbase/analytics.py:32–43

(self,
                 connection,
                 loop,
                 query_params,
                 row_factory=lambda x: x,
                 **kwargs
                 )

class AsyncAnalyticsRequest(AnalyticsRequestLogic):
    def __init__(self,
                 connection,
                 loop,
                 query_params,
                 row_factory=lambda x: x,
                 **kwargs
                 ):
        num_workers = kwargs.pop('num_workers', None) or 1
        super().__init__(connection, query_params, row_factory=row_factory, **kwargs)
        self._loop = loop
        self._tp_executor = ThreadPoolExecutor(num_workers)
        self._executor_shutdown = False

    @property
    def loop(self):