blob: 383ab8c0d034ac31d0b6ce8a03e7f5efc8ad314b (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
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
}
|
