highperfocused/go-nostr
1
0
Fork 0
mirror of https://github.com/nbd-wtf/go-nostr.git synced 2025-11-20 02:57:42 +01:00
Code Issues Packages Projects Releases Wiki Activity

make sub.Events a channel of pointers.

Browse Source
This commit is contained in:
fiatjaf
2023-01-26 09:04:27 -03:00
parent 0e2ee85785
commit 92c0143762
2 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
relay.go
View File

@@ -159,7 +159,7 @@ func (r *Relay) Connect(ctx context.Context) error {
if !subscription.Filters.Match(&event) || subscription.stopped { if !subscription.Filters.Match(&event) || subscription.stopped {
return return
} }
subscription.Events <- event subscription.Events <- &event
}() }()
} }
case "EOSE": case "EOSE":
@@ -329,7 +329,7 @@ func (r *Relay) Subscribe(ctx context.Context, filters Filters) *Subscription {
return sub 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}) sub := r.Subscribe(ctx, Filters{filter})
defer sub.Unsub() defer sub.Unsub()
@@ -340,7 +340,7 @@ func (r *Relay) QuerySync(ctx context.Context, filter Filter) []Event {
defer cancel() defer cancel()
} }
var events []Event var events []*Event
for { for {
select { select {
case evt := <-sub.Events: case evt := <-sub.Events:
@@ -366,7 +366,7 @@ func (r *Relay) prepareSubscription(id string) *Subscription {
Relay: r, Relay: r,
conn: r.Connection, conn: r.Connection,
id: id, id: id,
Events: make(chan Event), Events: make(chan *Event),
EndOfStoredEvents: make(chan struct{}, 1), EndOfStoredEvents: make(chan struct{}, 1),
} }

2
subscription.go
View File

@@ -12,7 +12,7 @@ type Subscription struct {
Relay *Relay Relay *Relay
Filters Filters Filters Filters
Events chan Event Events chan *Event
EndOfStoredEvents chan struct{} EndOfStoredEvents chan struct{}
stopped bool stopped bool