Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for writeErrCh (0.13 sec)

  1. staging/src/k8s.io/apiserver/pkg/server/filters/timeout_test.go

    	defer r.lock.Unlock()
    	return r.count
    }
    
    func newHandler(responseCh <-chan string, panicCh <-chan interface{}, writeErrCh chan<- error) http.HandlerFunc {
    	return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
    		select {
    		case resp := <-responseCh:
    			_, err := w.Write([]byte(resp))
    			writeErrCh <- err
    		case panicReason := <-panicCh:
    			panic(panicReason)
    		}
    	})
    }
    
    func TestTimeout(t *testing.T) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 26 16:28:45 UTC 2024
    - 18.4K bytes
    - Viewed (0)
Back to top