From c9b16c884c9797f5cdde9c2aeba2c20320213cd6 Mon Sep 17 00:00:00 2001 From: mitchsw Date: Tue, 28 Jun 2022 13:37:44 -0400 Subject: [PATCH] transport: remove unused `bufWriter.onFlush()` (#5464) --- internal/transport/http_util.go | 5 ----- 1 file changed, 5 deletions(-) diff --git a/internal/transport/http_util.go b/internal/transport/http_util.go index d8247bcdf692..b77513068622 100644 --- a/internal/transport/http_util.go +++ b/internal/transport/http_util.go @@ -322,8 +322,6 @@ type bufWriter struct { batchSize int conn net.Conn err error - - onFlush func() } func newBufWriter(conn net.Conn, batchSize int) *bufWriter { @@ -360,9 +358,6 @@ func (w *bufWriter) Flush() error { if w.offset == 0 { return nil } - if w.onFlush != nil { - w.onFlush() - } _, w.err = w.conn.Write(w.buf[:w.offset]) w.offset = 0 return w.err