func io.LimitReader
13 uses
io (current package)
io.go#L361: written, err = Copy(dst, LimitReader(src, n))
io.go#L458: func LimitReader(r Reader, n int64) Reader { return &LimitedReader{r, n} }
github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream
decode.go#L74: lr := io.LimitReader(hashReader, int64(prelude.HeadersLen))
decode.go#L82: buf, err := decodePayload(payloadBuf, io.LimitReader(hashReader, int64(payloadLen)))
github.com/aws/aws-sdk-go-v2/service/internal/checksum
aws_chunked_encoding.go#L359: n, err := io.Copy(r.chunkBuffer, io.LimitReader(r.reader, int64(r.chunkSize)))
go.pact.im/x/extraio
hash.go#L20: return io.LimitReader(NewHashReader(h), n)
google.golang.org/grpc
rpc_util.go#L744: bytesRead, err := buf.ReadFrom(io.LimitReader(dcReader, int64(maxReceiveMessageSize)+1))
rpc_util.go#L750: d, err = io.ReadAll(io.LimitReader(dcReader, int64(maxReceiveMessageSize)+1))
net/http
request.go#L1210: reader = io.LimitReader(r.Body, maxFormSize+1)
server.go#L585: n0, err := io.CopyBuffer(writerOnly{w}, io.LimitReader(src, sniffLen), buf)
transfer.go#L369: ncopy, err = t.doBodyCopy(w, io.LimitReader(body, t.ContentLength))
transfer.go#L566: t.Body = &body{src: io.LimitReader(r, realLength), closing: t.Close}
net/http/httputil
dump.go#L83: req.Body = io.NopCloser(io.LimitReader(neverEnding('x'), contentLength))