diff --git a/eliofile/eliofile.go b/eliofile/eliofile.go index 8cd6df8..85d7de7 100644 --- a/eliofile/eliofile.go +++ b/eliofile/eliofile.go @@ -24,7 +24,7 @@ type CountryCsvData struct { Data []string } -type ElioHandleFunc func(filename string, data chan<- CountryCsvData) bool +type ElioHandleFunc func(ctx context.Context, filename string, data chan<- CountryCsvData) bool type ElioDateiFoo struct { process ElioHandleFunc @@ -93,7 +93,7 @@ func (f *ElioDateiFoo) ScanCsv(ctx context.Context, data chan<- CountryCsvData) f.mu.Lock() f.haveDone[v.filename] = time.Now() f.mu.Unlock() - f.process(v.filename, data) + f.process(ctx, v.filename, data) } } }