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) +}