###############################################################################
# Description
###############################################################################

# Enforce latest record

###############################################################################
# Public functions
###############################################################################

def latest(stream, latest):
    for record in stream:
        if record.record_type=="event":
            if record.id > latest:
                break
            else:
                yield record
        else:
            yield record