enhancement: close channel before deleting the client

leonsteinhaeuser · Apr 13, 2022 · 6567b13 · 6567b13
1 parent 21b02b2
commit 6567b13
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/observer.go b/observer.go
@@ -56,6 +56,7 @@ func (o *Observer[t]) deleteClient(uid string) error {
 	if _, ok := o.clients[uid]; !ok {
 		return ErrClientAlreadyDeRegistered
 	}
+	close(o.clients[uid])
 	delete(o.clients, uid)
 	return nil
 }