Commit 251b916c authored by Brian Tiger Chow's avatar Brian Tiger Chow

style: readability

@jbenet

License: MIT
Signed-off-by: default avatarBrian Tiger Chow <brian@perfmode.com>
parent 1026244f
...@@ -149,7 +149,8 @@ func (dht *IpfsDHT) FindProvidersAsync(ctx context.Context, key u.Key, count int ...@@ -149,7 +149,8 @@ func (dht *IpfsDHT) FindProvidersAsync(ctx context.Context, key u.Key, count int
} }
var wg sync.WaitGroup var wg sync.WaitGroup
for _, pp := range dht.routingTables[0].NearestPeers(kb.ConvertKey(key), AlphaValue) { peers := dht.routingTables[0].NearestPeers(kb.ConvertKey(key), AlphaValue)
for _, pp := range peers {
wg.Add(1) wg.Add(1)
go func(p peer.Peer) { go func(p peer.Peer) {
defer wg.Done() defer wg.Done()
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment