- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for ioHandler (0.36 sec)
-
src/net/http/transport_test.go
retry := true for retry && !t.Failed() { var srvWG sync.WaitGroup inHandler := make(chan bool, 1) mux := NewServeMux() mux.HandleFunc("/fast", func(w ResponseWriter, r *Request) { inHandler <- true srvWG.Done() }) mux.HandleFunc("/slow", func(w ResponseWriter, r *Request) { inHandler <- true <-r.Context().Done() srvWG.Done() })
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 192.6K bytes - Viewed (0) -
src/net/http/serve_test.go
} func testServerRequestContextCancel_ConnClose(t *testing.T, mode testMode) { inHandler := make(chan struct{}) handlerDone := make(chan struct{}) ts := newClientServerTest(t, mode, HandlerFunc(func(w ResponseWriter, r *Request) { close(inHandler) <-r.Context().Done() close(handlerDone) })).ts c, err := net.Dial("tcp", ts.Listener.Addr().String())
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 202K bytes - Viewed (0)