Fix: Check if channel is closed.

This commit is contained in:
Kleissner
2021-04-25 00:07:53 +02:00
parent 63e736486a
commit 1c03afd63b

View File

@@ -51,7 +51,11 @@ func (dht *DHT) NewInformationRequest(Action int, Key []byte, Nodes []*Node) (ir
func (ir *InformationRequest) CollectResults(timeout time.Duration) (results []*NodeMessage) {
for {
select {
case result := <-ir.ResultChan:
case result, ok := <-ir.ResultChan:
if !ok { // channel closed?
return
}
results = append(results, result)
case <-time.After(timeout):