summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorNick White <git@njw.name>2021-05-19 22:27:37 +0100
committerNick White <git@njw.name>2021-05-19 22:27:37 +0100
commit2ac2807916fbf36e1fce5726ac102ab66f14d4ad (patch)
tree4e1aba8cc0238a02271d805fdac683efa8c55e3f
parentd96a4c93e1745a7a648f8fdddae2e2199c06dfca (diff)
Close process channel after writing to err channel in download(), in case of an error
This is needed so that in tests the error can be selected out reliably, rather than an empty process signal.
-rw-r--r--internal/pipeline/pipeline.go2
1 files changed, 1 insertions, 1 deletions
diff --git a/internal/pipeline/pipeline.go b/internal/pipeline/pipeline.go
index 5ba0cb4..72d7fd1 100644
--- a/internal/pipeline/pipeline.go
+++ b/internal/pipeline/pipeline.go
@@ -87,8 +87,8 @@ func download(dl chan string, process chan string, conn Pipeliner, dir string, e
if err != nil {
for range dl {
} // consume the rest of the receiving channel so it isn't blocked
- close(process)
errc <- err
+ close(process)
return
}
process <- fn