From 43535fe50f178d0073a2d457470302a89ac44efe Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Michael=20Mur=C3=A9?= Date: Wed, 24 Jul 2019 12:21:59 +0200 Subject: [PATCH] update the the last go-merkledag This commit was moved from ipfs/go-unixfs@e1cb36fcbf74a306e11e5b27525aedca3150f3c3 --- unixfs/ipld-merkledag/hamt/hamt.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/unixfs/ipld-merkledag/hamt/hamt.go b/unixfs/ipld-merkledag/hamt/hamt.go index c44b1789f..9bf67505b 100644 --- a/unixfs/ipld-merkledag/hamt/hamt.go +++ b/unixfs/ipld-merkledag/hamt/hamt.go @@ -330,7 +330,7 @@ func (ds *Shard) ForEachLink(ctx context.Context, f func(*ipld.Link) error) erro } // EnumLinksAsync returns a channel which will receive Links in the directory -// as they are enumerated, where order is not gauranteed +// as they are enumerated, where order is not guaranteed func (ds *Shard) EnumLinksAsync(ctx context.Context) <-chan format.LinkResult { linkResults := make(chan format.LinkResult) ctx, cancel := context.WithCancel(ctx) @@ -339,7 +339,7 @@ func (ds *Shard) EnumLinksAsync(ctx context.Context) <-chan format.LinkResult { defer cancel() getLinks := makeAsyncTrieGetLinks(ds.dserv, linkResults) cset := cid.NewSet() - err := dag.WalkParallel(ctx, getLinks, ds.cid, cset.Visit) + err := dag.Walk(ctx, getLinks, ds.cid, cset.Visit, dag.Concurrent()) if err != nil { emitResult(ctx, linkResults, format.LinkResult{Link: nil, Err: err}) }