diff --git a/khatru/handlers.go b/khatru/handlers.go index d0d92ba..6323279 100644 --- a/khatru/handlers.go +++ b/khatru/handlers.go @@ -273,7 +273,7 @@ func (rl *Relay) HandleWebsocket(w http.ResponseWriter, r *http.Request) { case *nostr.ReqEnvelope: eose := sync.WaitGroup{} - eose.Add(1) + eose.Add(len(env.Filters)) // a context just for the "stored events" request handler reqCtx, cancelReqCtx := context.WithCancelCause(ctx)