Use res.NextSync() instead of res.Next() to avoid using a channel.

ce68333c · Kevin Atkinson · a72dd86f · ce68333c
Commit ce68333c authored Nov 22, 2016 by Kevin Atkinson
Hide whitespace changes
Inline Side-by-side

Showing with 5 additions and 1 deletion

providers/providers.go providers/providers.go +5 -1

No files found.
--- a/providers/providers.go
+++ b/providers/providers.go
@@ -118,7 +118,11 @@ func loadProvSet(dstore ds.Datastore, k *cid.Cid) (*providerSet, error) {
 	}

 	out := newProviderSet()
-	for e := range res.Next() {
+	for {
+		e, ok := res.NextSync()
+		if !ok {
+			break
+		}
 		if e.Error != nil {
 			log.Error("got an error: ", e.Error)
 			continue