MCPcopy
hub / github.com/segmentio/kafka-go / discardN

Function discardN

discard.go:5–16  ·  view source on GitHub ↗
(r *bufio.Reader, sz int, n int)

Source from the content-addressed store, hash-verified

3import "bufio"
4
5func discardN(r *bufio.Reader, sz int, n int) (int, error) {
6 var err error
7 if n <= sz {
8 n, err = r.Discard(n)
9 } else {
10 n, err = r.Discard(sz)
11 if err == nil {
12 err = errShortRead
13 }
14 }
15 return sz - n, err
16}
17
18func discardInt32(r *bufio.Reader, sz int) (int, error) {
19 return discardN(r, sz, 4)

Callers 9

TestDiscardNFunction · 0.85
discardNMethod · 0.85
extractOffsetFunction · 0.85
readResponseMethod · 0.85
discardInt32Function · 0.85
discardStringFunction · 0.85
discardBytesFunction · 0.85
peekReadFunction · 0.85
ReadMethod · 0.85

Calls 1

DiscardMethod · 0.65

Tested by 1

TestDiscardNFunction · 0.68