diff options
| author | Paul Buetow <paul@buetow.org> | 2026-03-08 09:35:18 +0200 |
|---|---|---|
| committer | Paul Buetow <paul@buetow.org> | 2026-03-08 09:35:18 +0200 |
| commit | 77b41ce17090008470c261d1f185da43f76ec0c2 (patch) | |
| tree | 776f558ce855b52fc4b25281c08c93d81c69eafa /internal/io/fs/readfile_processor.go | |
| parent | f7f98ccaffc1be88db6f9814fb3c88b5f0a6ea34 (diff) | |
task: propagate dropped processing and flush errors (task 379)
Diffstat (limited to 'internal/io/fs/readfile_processor.go')
| -rw-r--r-- | internal/io/fs/readfile_processor.go | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/internal/io/fs/readfile_processor.go b/internal/io/fs/readfile_processor.go index 94a28dc..c68048d 100644 --- a/internal/io/fs/readfile_processor.go +++ b/internal/io/fs/readfile_processor.go @@ -156,7 +156,9 @@ func (f *readFile) handleReadErrorProcessor(ctx context.Context, err error, fd * if len(message.Bytes()) > 0 { // Process the last line if it doesn't end with newline f.updatePosition() - processor.ProcessFilteredLine(message) + if processErr := processor.ProcessFilteredLine(message); processErr != nil { + return abortReading, processErr + } } return abortReading, nil } |