(t *testing.T)
| 3034 | } |
| 3035 | |
| 3036 | func TestContextStreamWithClientGone(t *testing.T) { |
| 3037 | w := CreateTestResponseRecorder() |
| 3038 | c, _ := CreateTestContext(w) |
| 3039 | |
| 3040 | c.Stream(func(writer io.Writer) bool { |
| 3041 | defer func() { |
| 3042 | w.closeClient() |
| 3043 | }() |
| 3044 | |
| 3045 | _, err := writer.Write([]byte("test")) |
| 3046 | require.NoError(t, err) |
| 3047 | |
| 3048 | return true |
| 3049 | }) |
| 3050 | |
| 3051 | assert.Equal(t, "test", w.Body.String()) |
| 3052 | } |
| 3053 | |
| 3054 | func TestContextResetInHandler(t *testing.T) { |
| 3055 | w := CreateTestResponseRecorder() |
nothing calls this directly
no test coverage detected