Daten Channel in ScanCsv schließen.
This commit is contained in:
parent
a8cf840640
commit
504cebebb9
|
|
@ -47,6 +47,7 @@ func NewElioDateiFoo(lookUpDir string, process ElioHandleFunc) *ElioDateiFoo {
|
||||||
// Veraltete Dateien mit Präfix no-import und Postifx .old benennen.
|
// Veraltete Dateien mit Präfix no-import und Postifx .old benennen.
|
||||||
// Gültige Dateinamen zur Extraktion in Closure übergeben.
|
// Gültige Dateinamen zur Extraktion in Closure übergeben.
|
||||||
func (f *ElioDateiFoo) ScanCsv(data chan<- CountryCsvData) {
|
func (f *ElioDateiFoo) ScanCsv(data chan<- CountryCsvData) {
|
||||||
|
defer close(data)
|
||||||
files, err := os.ReadDir(f.lookUpDir)
|
files, err := os.ReadDir(f.lookUpDir)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
fmt.Println(err)
|
fmt.Println(err)
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue