wait for command to finish before closing the channel
This commit is contained in:
parent
fc9658ecf4
commit
7f63e585ee
@ -293,8 +293,9 @@ func revListShas(refLeft, refRight string, opt *ScanRefsOptions) (chan string, e
|
||||
}
|
||||
revs <- sha1
|
||||
}
|
||||
|
||||
cmd.Wait()
|
||||
close(revs)
|
||||
cmd.Cmd.Wait()
|
||||
}()
|
||||
|
||||
return revs, nil
|
||||
@ -344,8 +345,9 @@ func revListIndex(cache bool, indexMap *indexFileMap) (chan string, error) {
|
||||
revs <- sha1
|
||||
}
|
||||
}
|
||||
|
||||
cmd.Wait()
|
||||
close(revs)
|
||||
cmd.Cmd.Wait()
|
||||
}()
|
||||
|
||||
return revs, nil
|
||||
@ -382,8 +384,9 @@ func catFileBatchCheck(revs chan string) (chan string, error) {
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
cmd.Wait()
|
||||
close(smallRevs)
|
||||
cmd.Cmd.Wait()
|
||||
}()
|
||||
|
||||
go func() {
|
||||
@ -440,8 +443,9 @@ func catFileBatch(revs chan string) (chan *WrappedPointer, error) {
|
||||
break
|
||||
}
|
||||
}
|
||||
|
||||
cmd.Wait()
|
||||
close(pointers)
|
||||
cmd.Cmd.Wait()
|
||||
}()
|
||||
|
||||
go func() {
|
||||
|
Loading…
Reference in New Issue
Block a user