From e02e3ca9414f04387e4ede775d116e3c9182c887 Mon Sep 17 00:00:00 2001
From: the ming <mwei0210@users.noreply.github.com>
Date: Fri, 29 Mar 2024 02:09:38 +0800
Subject: [PATCH] close stream (#185)

---
 rpc/ws/subscription.go | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/rpc/ws/subscription.go b/rpc/ws/subscription.go
index c1bebf6d..c209cdaf 100644
--- a/rpc/ws/subscription.go
+++ b/rpc/ws/subscription.go
@@ -61,4 +61,6 @@ func (s *Subscription) Unsubscribe() {
 
 func (s *Subscription) unsubscribe(err error) {
 	s.closeFunc(err)
+	close(s.stream)
+	close(s.err)
 }