Test_HostClientTransport_StreamResponseBody() — fiber Function Reference

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

Function go FiberClient Transport

Entity Profile

FiberClient→ Transport→ Test_HostClientTransport_StreamResponseBody() — fiber Function Reference

Dependency Diagram

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

Relationship Graph

Source Code

client/transport_test.go lines 380–409

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

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

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

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