1 files changed, 23 insertions, 0 deletions

diff --git a/transport/channel.go b/transport/channel.go
new file mode 100644
index 0000000..56d5f2b
--- /dev/null
+++ b/transport/channel.go
@@ -0,0 +1,23 @@
+package transport
+
+import (
+        "context"
+
+        "flux/core"
+)
+
+type Receiver[T any] interface {
+        // Receive returns the next record, or ok=false once the stream is done or
+        // ctx is cancelled.
+        Receive(ctx context.Context) (core.StreamRecord[T], bool)
+        Close() error
+}
+
+// Emitter mirrors core.Emitter plus Close. It is declared separately because
+// core cannot import transport without an import cycle.
+type Emitter[T any] interface {
+        // Emit blocks until the record is handed off, or returns ctx.Err() if ctx
+        // is cancelled first.
+        Emit(ctx context.Context, record core.StreamRecord[T]) error
+        Close() error
+}