diff --git a/eliofile/eliofile.go b/eliofile/eliofile.go index 442f4ce..5cbc57b 100644 --- a/eliofile/eliofile.go +++ b/eliofile/eliofile.go @@ -46,7 +46,7 @@ func NewElioDateiFoo(lookUpDir string, process ElioHandleFunc) *ElioDateiFoo { // Warenhausnamen in eine eine Hashmap ablegen. Dopplungen mit dem spätesten Zeitpunkt behalten. // Veraltete Dateien mit Präfix no-import und Postifx .old benennen. // Gültige Dateinamen zur Extraktion in Closure übergeben. -func (f *ElioDateiFoo) ScanCsv() { +func (f *ElioDateiFoo) ScanCsv(data chan<- CountryCsvData) { files, err := os.ReadDir(f.lookUpDir) if err != nil { fmt.Println(err) @@ -76,8 +76,6 @@ func (f *ElioDateiFoo) ScanCsv() { } } - //BufferedChannel mit Platz für 10 Datensätzen - dataChannel := make(chan CountryCsvData, 10) for _, v := range filemap { f.mu.RLock() _, ok := f.haveDone[v.filename] @@ -89,6 +87,6 @@ func (f *ElioDateiFoo) ScanCsv() { f.mu.Lock() f.haveDone[v.filename] = time.Now() f.mu.Unlock() - go f.process(v.filename, dataChannel) + go f.process(v.filename, data) } }