1 files changed, 13 insertions, 0 deletions
diff --git a/transport/channel.go b/transport/channel.go
new file mode 100644
index 0000000..011f8ae
--- /dev/null
+++ b/transport/channel.go
@@ -0,0 +1,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
+}