diff --git a/transport/writer.go b/transport/writer.go
index 8b2e7b4..39baeef 100644
--- a/transport/writer.go
+++ b/transport/writer.go
@@ -10,4 +10,8 @@ type Writer interface {
 	// Flush writes any buffered messages to the channel.
 	// If the implementation does not support buffering. this is a noop.
 	Flush() error
+
+	// Close closes the writer
+	// Any blocked Flush or Write operations will be unblocked.
+	Close() error
 }