diff --git a/relaypool.go b/relaypool.go index 631cbd3..deaa330 100644 --- a/relaypool.go +++ b/relaypool.go @@ -181,7 +181,7 @@ func (r *RelayPool) Sub(filters EventFilters) *Subscription { random := make([]byte, 7) rand.Read(random) - subscription := Subscription{} + subscription := Subscription{filters: filters} subscription.channel = hex.EncodeToString(random) subscription.relays = make(map[string]*websocket.Conn) for relay, policy := range r.Relays { @@ -194,7 +194,7 @@ func (r *RelayPool) Sub(filters EventFilters) *Subscription { subscription.UniqueEvents = make(chan Event) r.subscriptions[subscription.channel] = &subscription - subscription.Sub(filters) + subscription.Sub() return &subscription } diff --git a/subscription.go b/subscription.go index 8548c9e..22b8cc5 100644 --- a/subscription.go +++ b/subscription.go @@ -36,7 +36,7 @@ func (subscription Subscription) Unsub() { } } -func (subscription Subscription) Sub(filters EventFilters) { +func (subscription Subscription) Sub() { for _, ws := range subscription.relays { message := []interface{}{ "REQ",