Method __init__

acouchbase/views.py:32–42

(self,
                 connection,
                 loop,
                 encoded_query,
                 **kwargs
                 )

class AsyncViewRequest(ViewRequestLogic):
    def __init__(self,
                 connection,
                 loop,
                 encoded_query,
                 **kwargs
                 ):
        num_workers = kwargs.pop('num_workers', None) or 1
        super().__init__(connection, encoded_query, **kwargs)
        self._loop = loop
        self._tp_executor = ThreadPoolExecutor(num_workers)
        self._executor_shutdown = False

    @property
    def loop(self):