diff --git a/internal/uploader/uploader.go b/internal/uploader/uploader.go index 041400f..a05e224 100644 --- a/internal/uploader/uploader.go +++ b/internal/uploader/uploader.go @@ -226,6 +226,7 @@ func processFile(ctx context.Context, logChan *chan string, filePath string, fil for i := 0; i < config.APPConfig.ThreadCount; i++ { select { case <-ctx.Done(): + close(lines) return default: go func() {