From c22550514341175497539f232a0e759f03fb0d58 Mon Sep 17 00:00:00 2001 From: Henrik Hautakoski Date: Wed, 29 Mar 2023 11:52:31 +0200 Subject: [PATCH] transport/writer.go: Add Close() method. --- transport/writer.go | 4 ++++ 1 file changed, 4 insertions(+) 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 }