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/server/handlers/turbo_writer.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) (limited to 'internal/server') diff --git a/internal/server/handlers/turbo_writer.go b/internal/server/handlers/turbo_writer.go index c687edf..af124e9 100644 --- a/internal/server/handlers/turbo_writer.go +++ b/internal/server/handlers/turbo_writer.go @@ -2,6 +2,7 @@ package handlers import ( "bytes" + "errors" "fmt" "io" "sync" @@ -170,7 +171,7 @@ func (w *DirectTurboWriter) Flush() error { if w.serverless { // Ensure writer is flushed if it supports it if flusher, ok := w.writer.(interface{ Flush() error }); ok { - flusher.Flush() + err = errors.Join(err, flusher.Flush()) } } -- cgit v1.2.3