Skip to content

Commit 2900da0

Browse files
authored
Merge pull request ipfs/go-unixfs#75 from MichaelMure/update-merkledag
update the the last go-merkledag This commit was moved from ipfs/go-unixfs@cb0d838
2 parents 856ed57 + 43535fe commit 2900da0

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

unixfs/ipld-merkledag/hamt/hamt.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -330,7 +330,7 @@ func (ds *Shard) ForEachLink(ctx context.Context, f func(*ipld.Link) error) erro
330330
}
331331

332332
// EnumLinksAsync returns a channel which will receive Links in the directory
333-
// as they are enumerated, where order is not gauranteed
333+
// as they are enumerated, where order is not guaranteed
334334
func (ds *Shard) EnumLinksAsync(ctx context.Context) <-chan format.LinkResult {
335335
linkResults := make(chan format.LinkResult)
336336
ctx, cancel := context.WithCancel(ctx)
@@ -339,7 +339,7 @@ func (ds *Shard) EnumLinksAsync(ctx context.Context) <-chan format.LinkResult {
339339
defer cancel()
340340
getLinks := makeAsyncTrieGetLinks(ds.dserv, linkResults)
341341
cset := cid.NewSet()
342-
err := dag.WalkParallel(ctx, getLinks, ds.cid, cset.Visit)
342+
err := dag.Walk(ctx, getLinks, ds.cid, cset.Visit, dag.Concurrent())
343343
if err != nil {
344344
emitResult(ctx, linkResults, format.LinkResult{Link: nil, Err: err})
345345
}

0 commit comments

Comments
 (0)