(p []byte)
| 678 | } |
| 679 | |
| 680 | func (lr *LimitReader) Read(p []byte) (int, error) { |
| 681 | sliceLen := int64(len(p)) |
| 682 | available := lr.bucket.TakeAvailable(sliceLen) |
| 683 | if available == 0 { |
| 684 | return 0, nil |
| 685 | } |
| 686 | if available == sliceLen { |
| 687 | return lr.reader.Read(p) |
| 688 | } |
| 689 | temp := make([]byte, available) |
| 690 | defer copy(p, temp) |
| 691 | return lr.reader.Read(temp) |
| 692 | } |
| 693 | |
| 694 | func sendRequestWithURL(URL *url.URL) http.Handler { |
| 695 | return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { |
nothing calls this directly
no outgoing calls
no test coverage detected