diff --git a/routing/dht/routing.go b/routing/dht/routing.go index bee640e8f..06fe39bcb 100644 --- a/routing/dht/routing.go +++ b/routing/dht/routing.go @@ -123,7 +123,7 @@ func (dht *IpfsDHT) Provide(key u.Key) error { } // 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) peerOut := make(chan *peer.Peer, count)