mirror of
https://github.com/fiatjaf/nak.git
synced 2025-12-08 16:48:51 +00:00
req: fix infinite loop when events channel is exhausted.
This commit is contained in:
8
req.go
8
req.go
@@ -308,9 +308,13 @@ example:
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
readevents:
|
||||||
for {
|
for {
|
||||||
select {
|
select {
|
||||||
case ie := <-results:
|
case ie, ok := <-results:
|
||||||
|
if !ok {
|
||||||
|
break readevents
|
||||||
|
}
|
||||||
stdout(ie.Event)
|
stdout(ie.Event)
|
||||||
case closed := <-closeds:
|
case closed := <-closeds:
|
||||||
if closed.HandledAuth {
|
if closed.HandledAuth {
|
||||||
@@ -318,6 +322,8 @@ example:
|
|||||||
} else {
|
} else {
|
||||||
log("%s CLOSED: %s\n", closed.Relay.URL, closed.Reason)
|
log("%s CLOSED: %s\n", closed.Relay.URL, closed.Reason)
|
||||||
}
|
}
|
||||||
|
case <-ctx.Done():
|
||||||
|
break readevents
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user