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

Method Reset

protocol/decode.go:29–36  ·  view source on GitHub ↗
(r io.Reader, n int)

Source from the content-addressed store, hash-verified

27}
28
29func (d *decoder) Reset(r io.Reader, n int) {
30 d.reader = r
31 d.remain = n
32 d.buffer = [8]byte{}
33 d.err = nil
34 d.table = nil
35 d.crc32 = 0
36}
37
38func (d *decoder) Read(b []byte) (int, error) {
39 if d.err != nil {

Callers 1

UnmarshalFunction · 0.45

Calls

no outgoing calls

Tested by

no test coverage detected