From b3f773655dc1c7b81dfe04108dac8a5cda46bac5 Mon Sep 17 00:00:00 2001 From: Henrik Hautakoski Date: Tue, 7 Mar 2023 11:35:13 +0100 Subject: [PATCH] Adding transport/reader.go --- transport/reader.go | 11 +++++++++++ 1 file changed, 11 insertions(+) create mode 100644 transport/reader.go diff --git a/transport/reader.go b/transport/reader.go new file mode 100644 index 0000000..70ffeb4 --- /dev/null +++ b/transport/reader.go @@ -0,0 +1,11 @@ +package transport + +// Reader interface defines the required method +// to read a message from an channel. +// +// This is a low-level interface typically implemented by transport drivers. +type Reader interface { + // Read a message from a channel. + // Read may block until a message is ready or an error occured. + Read(channel ChannelInterface) ([]byte, error) +}