'\param to_notify ApplyResult object to notify when all the
results we\'re waiting for become available. Can be None.'

def __init__(self, to_notify=None):

    AbstractResultCollector.__init__(self, to_notify)
    self._cond = threading.Condition()
    self._collection = []
    self._expected = 0
