From 50139c994e539f2f902fc0c06ab29ee93c1bc03c Mon Sep 17 00:00:00 2001 From: sangtran Date: Sat, 12 Sep 2026 16:35:06 +0700 Subject: refactor(event-time): make source timestamps authoritative --- core/operator/harness_test.go | 23 +++++++++++++++++++++++ 1 file changed, 23 insertions(+) create mode 100644 core/operator/harness_test.go (limited to 'core/operator/harness_test.go') diff --git a/core/operator/harness_test.go b/core/operator/harness_test.go new file mode 100644 index 0000000..383ab8c --- /dev/null +++ b/core/operator/harness_test.go @@ -0,0 +1,23 @@ +package operator_test + +import ( + "context" + + "flux/core" +) + +type captureEmitter[T any] struct { + records []core.StreamRecord[T] +} + +func (e *captureEmitter[T]) Emit(_ context.Context, record core.StreamRecord[T]) error { + e.records = append(e.records, record) + return nil +} + +func (e *captureEmitter[T]) Records() []core.StreamRecord[T] { + result := make([]core.StreamRecord[T], len(e.records)) + copy(result, e.records) + + return result +} -- cgit v1.3.1