(reader io.Reader, bucket *R.Bucket)
| 671 | } |
| 672 | |
| 673 | func NewLimitReader(reader io.Reader, bucket *R.Bucket) *LimitReader { |
| 674 | return &LimitReader{ |
| 675 | reader: reader, |
| 676 | bucket: bucket, |
| 677 | } |
| 678 | } |
| 679 | |
| 680 | func (lr *LimitReader) Read(p []byte) (int, error) { |
| 681 | sliceLen := int64(len(p)) |
no outgoing calls
no test coverage detected