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
 }