Skip to content

Commit

Permalink
Merge pull request ipfs/go-unixfs#75 from MichaelMure/update-merkledag
Browse files Browse the repository at this point in the history
update the the last go-merkledag

This commit was moved from ipfs/go-unixfs@cb0d838
  • Loading branch information
Stebalien authored Jul 25, 2019
2 parents 5536c4e + f3b59be commit 810918e
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions unixfs/hamt/hamt.go
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand All @@ -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})
}
Expand Down

0 comments on commit 810918e

Please sign in to comment.