diff --git a/relay.go b/relay.go
index 976170e..f4c069b 100644
--- a/relay.go
+++ b/relay.go
@@ -220,7 +220,7 @@ func (r *Relay) subscribe(id string, filters Filters) *Subscription {
 		conn:              r.Connection,
 		id:                id,
 		Events:            make(chan Event),
-		EndOfStoredEvents: make(chan struct{}),
+		EndOfStoredEvents: make(chan struct{}, 1),
 	}
 
 	r.subscriptions.Store(sub.id, &sub)