diff --git a/transport/transport_test.go b/transport/transport_test.go index 0e5dcb72..c03eed1d 100644 --- a/transport/transport_test.go +++ b/transport/transport_test.go @@ -116,11 +116,12 @@ func (h *testStreamHandler) handleStreamMisbehave(s *Stream) { size = http2MaxFrameLen } // Drain the client side stream flow control window. - var err error var sent int for sent <= initialWindowSize { <-conn.writableChan - if err = conn.framer.writeData(true, s.id, false, make([]byte, size)); err != nil { + if err := conn.framer.writeData(true, s.id, false, make([]byte, size)); err != nil { + conn.writableChan <- 0 + break } conn.writableChan <- 0 sent += size