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

Method Reset

compress/snappy/xerial.go:27–34  ·  view source on GitHub ↗
(r io.Reader)

Source from the content-addressed store, hash-verified

25}
26
27func (x *xerialReader) Reset(r io.Reader) {
28 x.reader = r
29 x.input = x.input[:0]
30 x.output = x.output[:0]
31 x.header = [16]byte{}
32 x.offset = 0
33 x.nbytes = 0
34}
35
36func (x *xerialReader) Read(b []byte) (int, error) {
37 for {

Callers 15

benchmarkCompressionFunction · 0.45
NewReaderMethod · 0.45
CloseMethod · 0.45
NewWriterMethod · 0.45
CloseMethod · 0.45
NewReaderMethod · 0.45
NewWriterMethod · 0.45
CloseMethod · 0.45
CloseMethod · 0.45
NewReaderMethod · 0.45
NewWriterMethod · 0.45
CloseMethod · 0.45

Calls

no outgoing calls

Tested by 1

benchmarkCompressionFunction · 0.36