def flush(self):
        if not self._events:
            return defer.succeed(None)
        d = defer.Deferred()
        self._flushObservers.append(d)
        return d
Return a Deferred that will fire (with None) when the call queue
dataset/ETHPy150Open warner/petmail/petmail/eventual.py/_SimpleCallQueue.flush