def flushEventualQueue(value=None):
    d = _theSimpleQueue.flush()
    d.addBoth(lambda _: value)
    return d
This returns a Deferred which fires when the eventual-send queue is
dataset/ETHPy150Open warner/petmail/petmail/eventual.py/flushEventualQueue