fix(merkle) use defer
Brian Tiger Chow committed
Dec 14, 2014 at 16:06 UTC
9420200a4e3432b130618a2a69d0f2cdb2cace5c
1 file changed
+2
-1
merkledag/merkledag.go
+2
-1
@@ -307,6 +307,8 @@ func FindLink(n *Node, k u.Key, found []*Node) (int, error) {
307
func (ds *dagService) GetDAG(ctx context.Context, root *Node) <-chan *Node {
308
sig := make(chan *Node)
309
go func() {
310
+ defer close(sig)
311
+
312
var keys []u.Key
313
for _, lnk := range root.Links {
314
keys = append(keys, u.Key(lnk.Hash))
@@ -350,7 +352,6 @@ func (ds *dagService) GetDAG(ctx context.Context, root *Node) <-chan *Node {
352
// TODO: bubble errors back up.
353
log.Errorf("Did not receive correct number of nodes!")
354
}
353
- close(sig)
355
}()
356
357
return sig