diff options
Diffstat (limited to 'core/operator.go')
| -rw-r--r-- | core/operator.go | 13 |
1 files changed, 0 insertions, 13 deletions
diff --git a/core/operator.go b/core/operator.go deleted file mode 100644 index 7785d44..0000000 --- a/core/operator.go +++ /dev/null @@ -1,13 +0,0 @@ -package core - -import "context" - -type Emitter[OUT any] interface { - Emit(ctx context.Context, record StreamRecord[OUT]) error -} - -type Operator[IN, OUT any] interface { - Open(ctx context.Context) error - Process(ctx context.Context, record StreamRecord[IN], out Emitter[OUT]) error - Close(ctx context.Context) error -} |