Test_StandardClientTransport_StreamResponseBody() — fiber Function Reference

Architecture documentation for the Test_StandardClientTransport_StreamResponseBody() function in transport_test.go from the fiber codebase.

Function go FiberClient Transport

Entity Profile

FiberClient→ Transport→ Test_StandardClientTransport_StreamResponseBody() — fiber Function Reference

Dependency Diagram

graph TD
  1b0933d9_2e86_4cd7_d6c9_e34f56011ae4["Test_StandardClientTransport_StreamResponseBody()"]
  b137f470_30b5_d002_b6e6_5173073c07e3["transport_test.go"]
  1b0933d9_2e86_4cd7_d6c9_e34f56011ae4 -->|defined in| b137f470_30b5_d002_b6e6_5173073c07e3
  style 1b0933d9_2e86_4cd7_d6c9_e34f56011ae4 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

client/transport_test.go lines 350–378

func Test_StandardClientTransport_StreamResponseBody(t *testing.T) {
	t.Parallel()

	t.Run("default value", func(t *testing.T) {
		t.Parallel()
		transport := newStandardClientTransport(&fasthttp.Client{})
		require.False(t, transport.StreamResponseBody())
	})

	t.Run("enable streaming", func(t *testing.T) {
		t.Parallel()
		client := &fasthttp.Client{}
		transport := newStandardClientTransport(client)
		transport.SetStreamResponseBody(true)
		require.True(t, transport.StreamResponseBody())
		require.True(t, client.StreamResponseBody)
	})

	t.Run("disable streaming", func(t *testing.T) {
		t.Parallel()
		client := &fasthttp.Client{}
		transport := newStandardClientTransport(client)
		transport.SetStreamResponseBody(true)
		require.True(t, transport.StreamResponseBody())
		transport.SetStreamResponseBody(false)
		require.False(t, transport.StreamResponseBody())
		require.False(t, client.StreamResponseBody)
	})
}