mirror of
https://github.com/ipfs/kubo.git
synced 2025-07-03 04:37:30 +08:00
fix(routing/dht) match the routing interface
the channel's "spin" is specified in the interface now =)
This commit is contained in:
@ -123,7 +123,7 @@ func (dht *IpfsDHT) Provide(key u.Key) error {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// FindProvidersAsync runs FindProviders and sends back results over a channel
|
// FindProvidersAsync runs FindProviders and sends back results over a channel
|
||||||
func (dht *IpfsDHT) FindProvidersAsync(key u.Key, count int, timeout time.Duration) chan *peer.Peer {
|
func (dht *IpfsDHT) FindProvidersAsync(key u.Key, count int, timeout time.Duration) <-chan *peer.Peer {
|
||||||
ctx, _ := context.WithTimeout(context.TODO(), timeout)
|
ctx, _ := context.WithTimeout(context.TODO(), timeout)
|
||||||
|
|
||||||
peerOut := make(chan *peer.Peer, count)
|
peerOut := make(chan *peer.Peer, count)
|
||||||
|
Reference in New Issue
Block a user