def save(record, store):
    try:
        store.write(record)
    finally:
        store.close()
    return True


def flush(items, log):
    try:
        return len(items)
    finally:
        for item in items:
            if item is None:
                continue
            if item == "stop":
                break
            log.append(item)

        def later():
            return "cleanup"
        log.append(later)
