1 files changed, 19 insertions, 0 deletions

diff --git a/unit_trace/latest.py b/unit_trace/latest.py
new file mode 100644
index 0000000..4abd3a2
--- /dev/null
+++ b/unit_trace/latest.py
@@ -0,0 +1,19 @@
+###############################################################################
+# Description
+###############################################################################
+
+# Enforce latest record
+
+###############################################################################
+# Public functions
+###############################################################################
+
+def latest(stream, latest):
+    for record in stream:
+        if record.record_type=="event":
+            if record.when > latest:
+                break
+            else:
+                yield record
+        else:
+            yield record