Code
Hub
Workspaces
Connect
Indexed graphs
Engine
MCP
copy
hub
/
github.com/segmentio/kafka-go
/ done
Method
done
protocol/decode.go:61–63 ·
view source on GitHub ↗
()
Source
from the content-addressed store, hash-verified
59
}
60
61
func
(d *decoder) done() bool {
62
return
d.remain == 0 || d.err != nil
63
}
64
65
func
(d *decoder) setCRC(table *crc32.Table) {
66
d.table, d.crc32 = table, 0
Callers
1
readFromVersion1
Method · 0.95
Calls
no outgoing calls
Tested by
no test coverage detected