From 77b41ce17090008470c261d1f185da43f76ec0c2 Mon Sep 17 00:00:00 2001 From: Paul Buetow Date: Sun, 8 Mar 2026 09:35:18 +0200 Subject: task: propagate dropped processing and flush errors (task 379) --- internal/io/fs/readfile_processor_optimized.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) (limited to 'internal/io/fs/readfile_processor_optimized.go') 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: -- cgit v1.2.3