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

Method NewWriter

compress/lz4/lz4.go:37–45  ·  view source on GitHub ↗

NewWriter implements the compress.Codec interface.

(w io.Writer)

Source from the content-addressed store, hash-verified

35
36// NewWriter implements the compress.Codec interface.
37func (c *Codec) NewWriter(w io.Writer) io.WriteCloser {
38 z, _ := writerPool.Get().(*lz4.Writer)
39 if z != nil {
40 z.Reset(w)
41 } else {
42 z = lz4.NewWriter(w)
43 }
44 return &writer{Writer: z}
45}
46
47type reader struct{ *lz4.Reader }
48

Callers

nothing calls this directly

Implementers 5

noopCodeccompress/compress_test.go
Codeccompress/zstd/zstd.go
Codeccompress/lz4/lz4.go
Codeccompress/snappy/snappy.go
Codeccompress/gzip/gzip.go

Calls 3

GetMethod · 0.80
NewWriterMethod · 0.65
ResetMethod · 0.45

Tested by

no test coverage detected