Code
Hub
Workspaces
Connect
Indexed graphs
Engine
MCP
copy
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
287
func
(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
293
func
(x *xerialWriter) full() bool {
294
return
len(x.input) == cap(x.input)
Callers
1
Flush
Method · 0.95
Calls
1
Write
Method · 0.45
Tested by
no test coverage detected