run(t, testServerReadAfterWriteHeader100Continue)
}
func testServerReadAfterWriteHeader100Continue(t *testing.T, mode testMode) {
+ t.Skip("https://go.dev/issue/67555")
body := []byte("body")
cst := newClientServerTest(t, mode, HandlerFunc(func(w ResponseWriter, r *Request) {
w.WriteHeader(200)
NewResponseController(w).Flush()
io.ReadAll(r.Body)
w.Write(body)
- }))
+ }), func(tr *Transport) {
+ tr.ExpectContinueTimeout = 24 * time.Hour // forever
+ })
req, _ := NewRequest("GET", cst.ts.URL, strings.NewReader("body"))
req.Header.Set("Expect", "100-continue")
run(t, testServerReadAfterHandlerDone100Continue)
}
func testServerReadAfterHandlerDone100Continue(t *testing.T, mode testMode) {
+ t.Skip("https://go.dev/issue/67555")
readyc := make(chan struct{})
cst := newClientServerTest(t, mode, HandlerFunc(func(w ResponseWriter, r *Request) {
go func() {
io.ReadAll(r.Body)
<-readyc
}()
- }))
+ }), func(tr *Transport) {
+ tr.ExpectContinueTimeout = 24 * time.Hour // forever
+ })
req, _ := NewRequest("GET", cst.ts.URL, strings.NewReader("body"))
req.Header.Set("Expect", "100-continue")
run(t, testServerReadAfterHandlerAbort100Continue)
}
func testServerReadAfterHandlerAbort100Continue(t *testing.T, mode testMode) {
+ t.Skip("https://go.dev/issue/67555")
readyc := make(chan struct{})
cst := newClientServerTest(t, mode, HandlerFunc(func(w ResponseWriter, r *Request) {
go func() {
<-readyc
}()
panic(ErrAbortHandler)
- }))
+ }), func(tr *Transport) {
+ tr.ExpectContinueTimeout = 24 * time.Hour // forever
+ })
req, _ := NewRequest("GET", cst.ts.URL, strings.NewReader("body"))
req.Header.Set("Expect", "100-continue")