task: propagate dropped processing and flush errors (task 379)

1 files changed, 2 insertions, 1 deletions

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())
 		}
 	}