From acc0b6fbaace61a3befd7f726f9d80fb69391126 Mon Sep 17 00:00:00 2001 From: SangTran-127 Date: Sat, 8 Aug 2026 12:54:43 +0700 Subject: implement core transport and processing operators with receiver, emitter, filter, and map functionalities --- transport/channel.go | 13 +++++++++++++ 1 file changed, 13 insertions(+) create mode 100644 transport/channel.go (limited to 'transport/channel.go') 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 +} -- cgit v1.2.3