From 09ea5d5758f28412cdfb4c6ca5e9716501157dbf Mon Sep 17 00:00:00 2001 From: fiatjaf Date: Sun, 28 Jan 2024 14:34:01 -0300 Subject: [PATCH] subscription.EndOfStoredEvents to have a capacity of 1 so it never gets deadlocked. --- relay.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/relay.go b/relay.go index 5ce9757..607ed00 100644 --- a/relay.go +++ b/relay.go @@ -385,7 +385,7 @@ func (r *Relay) PrepareSubscription(ctx context.Context, filters Filters, opts . cancel: cancel, counter: int(current), Events: make(chan *Event), - EndOfStoredEvents: make(chan struct{}), + EndOfStoredEvents: make(chan struct{}, 1), ClosedReason: make(chan string, 1), Filters: filters, }