diff --git a/relay.go b/relay.go index dd8ca41..086f6bd 100644 --- a/relay.go +++ b/relay.go @@ -159,7 +159,7 @@ func (r *Relay) Connect(ctx context.Context) error { if !subscription.Filters.Match(&event) || subscription.stopped { return } - subscription.Events <- event + subscription.Events <- &event }() } case "EOSE": @@ -329,7 +329,7 @@ func (r *Relay) Subscribe(ctx context.Context, filters Filters) *Subscription { return sub } -func (r *Relay) QuerySync(ctx context.Context, filter Filter) []Event { +func (r *Relay) QuerySync(ctx context.Context, filter Filter) []*Event { sub := r.Subscribe(ctx, Filters{filter}) defer sub.Unsub() @@ -340,7 +340,7 @@ func (r *Relay) QuerySync(ctx context.Context, filter Filter) []Event { defer cancel() } - var events []Event + var events []*Event for { select { case evt := <-sub.Events: @@ -366,7 +366,7 @@ func (r *Relay) prepareSubscription(id string) *Subscription { Relay: r, conn: r.Connection, id: id, - Events: make(chan Event), + Events: make(chan *Event), EndOfStoredEvents: make(chan struct{}, 1), } diff --git a/subscription.go b/subscription.go index 80eba4c..7f29ee9 100644 --- a/subscription.go +++ b/subscription.go @@ -12,7 +12,7 @@ type Subscription struct { Relay *Relay Filters Filters - Events chan Event + Events chan *Event EndOfStoredEvents chan struct{} stopped bool