

def flush(self):
    'Return a Deferred that will fire (with None) when the call queue\n        is completely empty.'
    if (not self._events):
        return defer.succeed(None)
    d = defer.Deferred()
    self._flushObservers.append(d)
    return d

dataset/ETHPy150Open warner/petmail/petmail/eventual.py _SimpleCallQueue.flush/original