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

Method setError

protocol/decode.go:172–177  ·  view source on GitHub ↗
(err error)

Source from the content-addressed store, hash-verified

170}
171
172func (d *decoder) setError(err error) {
173 if d.err == nil && err != nil {
174 d.err = err
175 d.discardAll()
176 }
177}
178
179func (d *decoder) readFull(b []byte) bool {
180 n, err := io.ReadFull(d, b)

Callers 7

discardMethod · 0.95
readMethod · 0.95
writeToMethod · 0.95
readFullMethod · 0.95
readVarIntMethod · 0.95
readUnsignedVarIntMethod · 0.95
readerDecodeFuncOfFunction · 0.80

Calls 1

discardAllMethod · 0.95

Tested by

no test coverage detected