Test_Ctx_SendStreamWriter() — fiber Function Reference

Architecture documentation for the Test_Ctx_SendStreamWriter() function in ctx_test.go from the fiber codebase.

Function go FiberCore Routing

Entity Profile

FiberCore→ Routing→ Test_Ctx_SendStreamWriter() — fiber Function Reference

Dependency Diagram

graph TD
  5f581eaf_1a23_f40a_7a59_07ccba067a0d["Test_Ctx_SendStreamWriter()"]
  7b3d4933_5ae3_f84d_ff6d_0cb34e268026["ctx_test.go"]
  5f581eaf_1a23_f40a_7a59_07ccba067a0d -->|defined in| 7b3d4933_5ae3_f84d_ff6d_0cb34e268026
  style 5f581eaf_1a23_f40a_7a59_07ccba067a0d fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

ctx_test.go lines 7216–7242

func Test_Ctx_SendStreamWriter(t *testing.T) {
	t.Parallel()
	app := New()
	c := app.AcquireCtx(&fasthttp.RequestCtx{})

	err := c.SendStreamWriter(func(w *bufio.Writer) {
		w.WriteString("Don't crash please") //nolint:errcheck // It is fine to ignore the error
	})
	require.NoError(t, err)
	require.Equal(t, "Don't crash please", string(c.Response().Body()))

	err = c.SendStreamWriter(func(w *bufio.Writer) {
		for lineNum := 1; lineNum <= 5; lineNum++ {
			fmt.Fprintf(w, "Line %d\n", lineNum)
			if flushErr := w.Flush(); flushErr != nil {
				t.Errorf("unexpected error: %s", flushErr)
				return
			}
		}
	})
	require.NoError(t, err)
	require.Equal(t, "Line 1\nLine 2\nLine 3\nLine 4\nLine 5\n", string(c.Response().Body()))

	err = c.SendStreamWriter(func(_ *bufio.Writer) {})
	require.NoError(t, err)
	require.Empty(t, c.Response().Body())
}