(p []byte)
| 110 | func (tw *timeoutWriter) Header() http.Header { return tw.h } |
| 111 | |
| 112 | func (tw *timeoutWriter) Write(p []byte) (int, error) { |
| 113 | tw.mu.Lock() |
| 114 | defer tw.mu.Unlock() |
| 115 | if tw.timedOut { |
| 116 | return 0, ErrHandlerTimeout |
| 117 | } |
| 118 | if !tw.wroteHeader { |
| 119 | tw.writeHeader(http.StatusOK) |
| 120 | } |
| 121 | return tw.wbuf.Write(p) |
| 122 | } |
| 123 | |
| 124 | func (tw *timeoutWriter) WriteHeader(code int) { |
| 125 | tw.mu.Lock() |
no test coverage detected