blob: 011f8ae2a703cb5a19b6301275f82c0df67f1389 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
|
package transport
import "goflink/core"
type Receiver[T any] interface {
Receive() (core.StreamRecord[T], bool)
Close() error
}
type Emitter[T any] interface {
Emit(core.StreamRecord[T]) error
Close() error
}
|