close stream (#185)

gagliardetto · Mar 28, 2024 · e02e3ca · e02e3ca
1 parent a8900f8
commit e02e3ca
Showing 1 changed file with 2 additions and 0 deletions.
diff --git 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)
 }