'Flush dirty (acked/rejected) tags from.'

def _flush(self):

    dirty = self._dirty
    delivered = self._delivered
    while 1:
        try:
            dirty_tag = dirty.pop()
        except KeyError:
            break
        delivered.pop(dirty_tag, None)
