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_optimized.go | |
| parent | f7f98ccaffc1be88db6f9814fb3c88b5f0a6ea34 (diff) | |
task: propagate dropped processing and flush errors (task 379)
Diffstat (limited to 'internal/io/fs/readfile_processor_optimized.go')
| -rw-r--r-- | internal/io/fs/readfile_processor_optimized.go | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/internal/io/fs/readfile_processor_optimized.go b/internal/io/fs/readfile_processor_optimized.go index 3e460ed..6447f89 100644 --- a/internal/io/fs/readfile_processor_optimized.go +++ b/internal/io/fs/readfile_processor_optimized.go @@ -368,7 +368,9 @@ func (f *readFile) tailWithProcessorOptimized(ctx context.Context, fd *os.File, f.updatePosition() lineBuf := pool.BytesBuffer.Get().(*bytes.Buffer) lineBuf.Write(partialLine.Bytes()) - filterProcessor.ProcessFilteredLine(lineBuf) + if err := filterProcessor.ProcessFilteredLine(lineBuf); err != nil { + return err + } } return nil default: |