Channel auf oberste Ebene ziehen.
This commit is contained in:
parent
5858e70c0d
commit
17365edbbb
|
|
@ -48,7 +48,6 @@ 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(ctx context.Context, data chan<- CountryCsvData) {
|
func (f *ElioDateiFoo) ScanCsv(ctx context.Context, data chan<- CountryCsvData) {
|
||||||
defer close(data)
|
|
||||||
select {
|
select {
|
||||||
case <-ctx.Done():
|
case <-ctx.Done():
|
||||||
fmt.Println("Abbruch angefordert im Verarbeitungsprozess.")
|
fmt.Println("Abbruch angefordert im Verarbeitungsprozess.")
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue