diff --git a/nip17/nip17.go b/nip17/nip17.go
index cd7d9b8..62a2454 100644
--- a/nip17/nip17.go
+++ b/nip17/nip17.go
@@ -72,6 +72,8 @@ func ListenForMessages(
 	ch := make(chan nostr.Event)
 
 	go func() {
+		defer close(ch)
+
 		for ie := range pool.SubMany(ctx, relays, nostr.Filters{
 			{
 				Kinds: []int{1059},