Bring back pipe closure from other end
Peter Rabbitson committed
Mar 27, 2020 at 19:53 UTC
ae5a9e0549f20497075a35e7fe3c436e92005ad9
1 file changed
+1
core/commands/dag/dag.go
+1
@@ -319,6 +319,7 @@ The output of blocks happens in strict DAG-traversal, first-seen, order.
319
}()
320
321
if err := res.Emit(pipeR); err != nil {
322
+ pipeR.Close() // ignore the error if any
323
return err
324
}
325