Merge bc46a095350725318e46839b7cd2ac4ae10d25c7 into 5c00df8afadd06cc5be530dde00fe6d9fa4a2e4a

context.go

@@ -1157,6 +1157,15 @@ func (c *Context) Render(code int, r render.Render) {
 		return
 	}
 
+	if c.Writer.Written() && IsDebugging() {
+		// Skip warning for SSE and streaming responses (status code -1)
+		if code != -1 {
+			if _, ok := r.(sse.Event); !ok {
+				debugPrint("[WARNING] Response body already written. Attempting to write again with status code %d", code)
+			}
+		}
+	}
+
 	if err := r.Render(c.Writer); err != nil {
 		// Pushing error to c.Errors
 		_ = c.Error(err)

context_test.go

@@ -1396,6 +1396,43 @@ func TestContextRenderNoContentData(t *testing.T) {
 	assert.Equal(t, "text/csv", w.Header().Get("Content-Type"))
 }
 
+// Test multiple JSON writes in debug mode
+func TestContextRenderMultipleJSON(t *testing.T) {
+	w := httptest.NewRecorder()
+	c, _ := CreateTestContext(w)
+
+	oldMode := os.Getenv("GIN_MODE")
+	defer os.Setenv("GIN_MODE", oldMode)
+	SetMode(DebugMode)
+
+	output := captureOutput(t, func() {
+		c.JSON(http.StatusOK, H{"foo": "bar"})
+		c.JSON(http.StatusOK, H{"baz": "qux"})
+	})
+
+	assert.Equal(t, http.StatusOK, w.Code)
+	assert.Contains(t, output, "[WARNING] Response body already written")
+	assert.Contains(t, output, "status code 200")
+}
+
+// Test multiple SSE writes in debug mode
+func TestContextRenderMultipleSSE(t *testing.T) {
+	w := httptest.NewRecorder()
+	c, _ := CreateTestContext(w)
+
+	oldMode := os.Getenv("GIN_MODE")
+	defer os.Setenv("GIN_MODE", oldMode)
+	SetMode(DebugMode)
+
+	output := captureOutput(t, func() {
+		c.SSEvent("message", "test1")
+		c.SSEvent("message", "test2")
+	})
+
+	assert.Equal(t, http.StatusOK, w.Code)
+	assert.NotContains(t, output, "[WARNING] Response body already written")
+}
+
 func TestContextRenderSSE(t *testing.T) {
 	w := httptest.NewRecorder()
 	c, _ := CreateTestContext(w)