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

Method Close

compress/snappy/snappy.go:102–110  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

100type writer struct{ *xerialWriter }
101
102func (w *writer) Close() (err error) {
103 if x := w.xerialWriter; x != nil {
104 w.xerialWriter = nil
105 err = x.Flush()
106 x.Reset(nil)
107 writerPool.Put(x)
108 }
109 return
110}

Callers

nothing calls this directly

Calls 3

PutMethod · 0.80
FlushMethod · 0.45
ResetMethod · 0.45

Tested by

no test coverage detected