problem: we lose every second event

Stackerstan · Dec 25, 2022 · ab062b1 · ab062b1
1 parent 3f2c3f1
commit ab062b1
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/relaypool.go b/relaypool.go
@@ -105,6 +105,7 @@ func (r *RelayPool) addConnected(relay *Relay, policy RelayPoolPolicy) {
 		go func(sub *Subscription) {
 			for evt := range sub.Events {
 				eventStream <- EventMessage{Relay: relay.URL, Event: evt}
+				eventStream <- EventMessage{Relay: relay.URL, Event: evt}
 			}
 		}(sub)