blob: 40d0ca65b92baffce0d9688cb1a08b5cc36fd85c (
plain)
1
2
3
4
5
6
7
8
9
10
11
|
package core
type Emitter[OUT any] interface {
Emit(record StreamRecord[OUT]) error
}
type Operator[IN, OUT any] interface {
Open() error
Process(record StreamRecord[IN], out Emitter[OUT]) error
Close() error
}
|