From 5d5c0ac4a3d908920edcd0d7b5ec509391010a54 Mon Sep 17 00:00:00 2001 From: Jean de Klerk Date: Fri, 8 Feb 2019 16:17:16 -0700 Subject: [PATCH] internal: check flush err (#2632) --- internal/transport/http2_client.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/internal/transport/http2_client.go b/internal/transport/http2_client.go index 22fa467a..ff8f4db0 100644 --- a/internal/transport/http2_client.go +++ b/internal/transport/http2_client.go @@ -322,7 +322,9 @@ func newHTTP2Client(connectCtx, ctx context.Context, addr TargetInfo, opts Conne } } - t.framer.writer.Flush() + if err := t.framer.writer.Flush(); err != nil { + return nil, err + } go func() { t.loopy = newLoopyWriter(clientSide, t.framer, t.controlBuf, t.bdpEst) err := t.loopy.run()