def __init__(self, api_call, bundle_id, bundled_field, bundling_request,
                 kwargs, subresponse_field=None):
        """
        Args:
           api_call (Callable[Sequence[object], object]): the func that is this
             tasks's API call.
           bundle_id (Tuple[str]): the id of this bundle.
           bundled_field (str): the field used to create the bundled request.
           bundling_request (object): the request to pass as the arg to
              api_call.
           kwargs (dict): keyword arguments passed to api_call.
           subresponse_field (str): optional field used to demultiplex
              responses.

        """
        self._api_call = api_call
        self._bundling_request = bundling_request
        self._kwargs = kwargs
        self.bundle_id = bundle_id
        self.bundled_field = bundled_field
        self.subresponse_field = subresponse_field
        self.timer = None
        self._in_deque = collections.deque()
        self._event_deque = collections.deque()
def __init__ ( self , api_call , bundle_id , bundled_field , bundling_request , kwargs , subresponse_field = None ) : self . _api_call = api_call self . _bundling_request = bundling_request self . _kwargs = kwargs self . bundle_id = bundle_id self . bundled_field = bundled_field self . subresponse_field = subresponse_field self . timer = None self . _in_deque = collections . deque ( ) self . _event_deque = collections . deque ( )
Args:
           api_call (Callable[Sequence[object], object]): the func that is this
             tasks's API call.
           bundle_id (Tuple[str]): the id of this bundle.
           bundled_field (str): the field used to create the bundled request.
           bundling_request (object): the request to pass as the arg to
              api_call.
           kwargs (dict): keyword arguments passed to api_call.
           subresponse_field (str): optional field used to demultiplex
              responses.