aboutsummaryrefslogtreecommitdiff
path: root/dna/drive.go
diff options
context:
space:
mode:
authorn-peugnet <n.peugnet@free.fr>2021-10-18 16:04:31 +0200
committern-peugnet <n.peugnet@free.fr>2021-10-18 16:04:31 +0200
commit56d1f553f32c242f7cc5043b9ce2b719e2285838 (patch)
treef73d85abb69b5b4a9f65aca197fcaf7dda40f99d /dna/drive.go
parent04563efa9c0dc1f6a36094dfd884ae432cf46b29 (diff)
downloaddna-backup-56d1f553f32c242f7cc5043b9ce2b719e2285838.tar.gz
dna-backup-56d1f553f32c242f7cc5043b9ce2b719e2285838.zip
make repo responsible of creating the export end channel
Diffstat (limited to 'dna/drive.go')
-rw-r--r--dna/drive.go5
1 files changed, 2 insertions, 3 deletions
diff --git a/dna/drive.go b/dna/drive.go
index 0f62d5e..317d2f4 100644
--- a/dna/drive.go
+++ b/dna/drive.go
@@ -89,7 +89,7 @@ func New(
}
}
-func (d *DnaDrive) ExportVersion() (export.Input, <-chan bool) {
+func (d *DnaDrive) ExportVersion(end chan<- bool) export.Input {
rChunks, wChunks := io.Pipe()
rRecipe, wRecipe := io.Pipe()
rFiles, wFiles := io.Pipe()
@@ -105,9 +105,8 @@ func (d *DnaDrive) ExportVersion() (export.Input, <-chan bool) {
Files: rFiles,
},
}
- end := make(chan bool)
go d.writeVersion(version.Output, end)
- return version.Input, end
+ return version.Input
}
func (d *DnaDrive) writeVersion(output export.Output, end chan<- bool) {