Skip to content

Commit c9b16c8

Browse files
authored
transport: remove unused bufWriter.onFlush() (#5464)
1 parent 755bf5a commit c9b16c8

File tree

1 file changed

+0
-5
lines changed

1 file changed

+0
-5
lines changed

internal/transport/http_util.go

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -322,8 +322,6 @@ type bufWriter struct {
322322
batchSize int
323323
conn net.Conn
324324
err error
325-
326-
onFlush func()
327325
}
328326

329327
func newBufWriter(conn net.Conn, batchSize int) *bufWriter {
@@ -360,9 +358,6 @@ func (w *bufWriter) Flush() error {
360358
if w.offset == 0 {
361359
return nil
362360
}
363-
if w.onFlush != nil {
364-
w.onFlush()
365-
}
366361
_, w.err = w.conn.Write(w.buf[:w.offset])
367362
w.offset = 0
368363
return w.err

0 commit comments

Comments
 (0)