diff options
author | n-peugnet <n.peugnet@free.fr> | 2021-10-18 16:04:31 +0200 |
---|---|---|
committer | n-peugnet <n.peugnet@free.fr> | 2021-10-18 16:04:31 +0200 |
commit | 56d1f553f32c242f7cc5043b9ce2b719e2285838 (patch) | |
tree | f73d85abb69b5b4a9f65aca197fcaf7dda40f99d /dna | |
parent | 04563efa9c0dc1f6a36094dfd884ae432cf46b29 (diff) | |
download | dna-backup-56d1f553f32c242f7cc5043b9ce2b719e2285838.tar.gz dna-backup-56d1f553f32c242f7cc5043b9ce2b719e2285838.zip |
make repo responsible of creating the export end channel
Diffstat (limited to 'dna')
-rw-r--r-- | dna/drive.go | 5 |
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) { |