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

Method write

compress/snappy/xerial.go:287–291  ·  view source on GitHub ↗
(b []byte)

Source from the content-addressed store, hash-verified

285}
286
287func (x *xerialWriter) write(b []byte) (int, error) {
288 n, err := x.writer.Write(b)
289 x.nbytes += int64(n)
290 return n, err
291}
292
293func (x *xerialWriter) full() bool {
294 return len(x.input) == cap(x.input)

Callers 1

FlushMethod · 0.95

Calls 1

WriteMethod · 0.45

Tested by

no test coverage detected