unit_trace/earliest.py


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

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

# Enforce earliest record

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

def earliest(stream, earliest):
    for record in stream:
        if record.record_type=="event":
            if record.id < earliest:
                pass
            else:
                yield record
                break
        else:
            yield record
    for record in stream:
        yield record