Test_Ctx_BodyStreamWriter() — fiber Function Reference

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

Function go FiberCore Routing

Entity Profile

FiberCore→ Routing→ Test_Ctx_BodyStreamWriter() — fiber Function Reference

Dependency Diagram

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

Relationship Graph

Source Code

ctx_test.go lines 7652–7674

func Test_Ctx_BodyStreamWriter(t *testing.T) {
	t.Parallel()
	ctx := &fasthttp.RequestCtx{}

	ctx.SetBodyStreamWriter(func(w *bufio.Writer) {
		fmt.Fprintf(w, "body writer line 1\n")
		if err := w.Flush(); err != nil {
			t.Errorf("unexpected error: %s", err)
		}
		fmt.Fprintf(w, "body writer line 2\n")
	})

	require.True(t, ctx.IsBodyStream())

	s := ctx.Response.String()
	br := bufio.NewReader(bytes.NewBufferString(s))
	var resp fasthttp.Response
	require.NoError(t, resp.Read(br))

	body := string(resp.Body())
	expectedBody := "body writer line 1\nbody writer line 2\n"
	require.Equal(t, expectedBody, body)
}