diff --git a/common/buf/writer.go b/common/buf/writer.go index f14d83c3d..882a49ad5 100644 --- a/common/buf/writer.go +++ b/common/buf/writer.go @@ -236,6 +236,10 @@ func (w *BufferedWriter) Close() error { return common.Close(w.writer) } +func (w *BufferedWriter) Interrupt() { + common.Interrupt(w.writer) +} + // SequentialWriter is a Writer that writes MultiBuffer sequentially into the underlying io.Writer. type SequentialWriter struct { io.Writer