From d04d1f3a3b39f8ac275d1543f5244a72cb9676d4 Mon Sep 17 00:00:00 2001
From: Sergey Cherepanov <cheggaaa@gmail.com>
Date: Mon, 30 Jan 2023 18:40:25 +0300
Subject: [PATCH] streampool: close dial queue

---
 net/streampool/streampool.go | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/net/streampool/streampool.go b/net/streampool/streampool.go
index fb53cd69..8319e972 100644
--- a/net/streampool/streampool.go
+++ b/net/streampool/streampool.go
@@ -332,6 +332,9 @@ func (s *streamPool) removeStream(streamId uint32) {
 }
 
 func (s *streamPool) Close() (err error) {
+	if e := s.dial.Close(); e != nil {
+		log.Warn("dial queue close error", zap.Error(e))
+	}
 	return s.exec.Close()
 }