Fix unsubscribe queue

2022-10-26 14:45:40 +03:00 · 2022-10-26 14:45:40 +03:00 · 8ed2e478d8
commit 8ed2e478d8
parent 493bf3ce15
1 changed files with 4 additions and 0 deletions
--- a/ytfunction.go
+++ b/ytfunction.go
@ -233,6 +233,10 @@ func (serve *Serve) Shutdown() {
 		value.subj.Unsubscribe()
 		close(value.inputChan)
 	}
+	err := serve.subj.Unsubscribe()
+	if err != nil {
+		panic(err)
+	}
 	close(serve.chanQueueCallback)
 	serve.nc.Close()