From 70bc68973623fdc5dc3e1009d395f0368f51ce3d Mon Sep 17 00:00:00 2001 From: Henrik Hautakoski Date: Wed, 29 Mar 2023 15:41:01 +0200 Subject: [PATCH] transport/reader.go: Add Close() method --- transport/reader.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/transport/reader.go b/transport/reader.go index b481330..0dcab66 100644 --- a/transport/reader.go +++ b/transport/reader.go @@ -10,4 +10,8 @@ type Reader interface { // // This function should be designed to handle concurrent calls. eg. thread safe. Read(channel Channel) ([]byte, error) + + // Close closes the reader + // Any blocked Read operations will be unblocked. + Close() error }