Function TestClientTimeoutBeforeStreaming

proxy/clienttimeout_test.go:196–229

(t *testing.T)

}

func TestClientTimeoutBeforeStreaming(t *testing.T) {
	testLog := NewTestLog()
	defer testLog.Close()

	backend := startTestServer([]byte("backend reply"), 0, func(*http.Request) {})
	defer backend.Close()

	doc := fmt.Sprintf(`hello: * -> latency("100ms") -> "%s"`, backend.URL)
	tp, err := newTestProxy(doc, FlagsNone)
	if err != nil {
		t.Fatal(err)
	}
	defer tp.close()

	ps := httptest.NewServer(tp.proxy)
	defer ps.Close()

	req, err := http.NewRequest("GET", ps.URL, nil)
	if err != nil {
		t.Fatal(err)
	}

	rsp, err := (&http.Client{
		Timeout: 50 * time.Millisecond,
	}).Do(req)
	if err == nil || rsp != nil {
		t.Errorf("unexpected err or response: %v %v", err, rsp)
	}

	const msg = "Client request: context canceled"
	if err = testLog.WaitFor(msg, 200*time.Millisecond); err != nil {
		t.Errorf("log should contain '%s'", msg)
	}
}