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
}