Skip to content

Commit f4519fc

Browse files
committed
send FIN in normal order instead of in priority
1 parent d245826 commit f4519fc

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

stream.go

+3-1
Original file line numberDiff line numberDiff line change
@@ -484,7 +484,9 @@ func (s *Stream) Close() error {
484484
})
485485

486486
if once {
487-
_, err = s.sess.writeFrame(newFrame(byte(s.sess.config.Version), cmdFIN, s.id))
487+
// send FIN in order
488+
f := newFrame(byte(s.sess.config.Version), cmdFIN, s.id)
489+
_, err = s.sess.writeFrameInternal(f, time.After(openCloseTimeout), CLSDATA)
488490
s.sess.streamClosed(s.id)
489491
return err
490492
} else {

0 commit comments

Comments
 (0)