Daten Channel hoch in die Signatur von Scancsv gezogen.

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)
 	}
 }