diff --git a/internal/module/http-server.go b/internal/module/http-server.go index 3fe8a6d..01ac186 100644 --- a/internal/module/http-server.go +++ b/internal/module/http-server.go @@ -194,9 +194,11 @@ func (hs *HTTPServer) Output(ctx context.Context, payload any) error { return errors.New("http.server is only able to output HTTPResponse") } + if responseWriter.done { + return errors.New("http.server response writer has already been written to") + } + responseWriter.WriteHeader(payloadResponse.Status) - responseWriter.Write(payloadResponse.Body) - return nil }