(re io.Reader)
| 109 | } |
| 110 | |
| 111 | func (d readerFromDelegator) ReadFrom(re io.Reader) (int64, error) { |
| 112 | // If applicable, call WriteHeader here so that observeWriteHeader is |
| 113 | // handled appropriately. |
| 114 | if !d.wroteHeader { |
| 115 | d.WriteHeader(http.StatusOK) |
| 116 | } |
| 117 | n, err := d.ResponseWriter.(io.ReaderFrom).ReadFrom(re) |
| 118 | d.written += n |
| 119 | return n, err |
| 120 | } |
| 121 | |
| 122 | func (d pusherDelegator) Push(target string, opts *http.PushOptions) error { |
| 123 | return d.ResponseWriter.(http.Pusher).Push(target, opts) |