From 6fc48c5dae4df0d1561afa9b36e79cef8d2792b7 Mon Sep 17 00:00:00 2001 From: Qian Wang Date: Sat, 27 Jul 2019 21:38:08 +0100 Subject: [PATCH] Fix a goroutine leak --- internal/multiplex/stream.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/multiplex/stream.go b/internal/multiplex/stream.go index 5a6585a..b56de88 100644 --- a/internal/multiplex/stream.go +++ b/internal/multiplex/stream.go @@ -112,6 +112,7 @@ func (stream *Stream) Write(in []byte) (n int, err error) { func (stream *Stream) passiveClose() { stream.heliumMask.Do(func() { close(stream.die) }) stream.session.delStream(stream.id) + stream.sortedBuf.Close() //log.Printf("%v passive closing\n", stream.id) }