Code
Hub
Workspaces
Connect
Indexed graphs
Engine
MCP
copy
hub
/
github.com/segmentio/kafka-go
/ readFull
Method
readFull
protocol/decode.go:179–183 ·
view source on GitHub ↗
(b []byte)
Source
from the content-addressed store, hash-verified
177
}
178
179
func
(d *decoder) readFull(b []byte) bool {
180
n, err := io.ReadFull(d, b)
181
d.setError(err)
182
return
n == len(b)
183
}
184
185
func
(d *decoder) readByte() byte {
186
if
d.readFull(d.buffer[:1]) {
Callers
6
readByte
Method · 0.95
readInt8
Method · 0.95
readInt16
Method · 0.95
readInt32
Method · 0.95
readInt64
Method · 0.95
readFloat64
Method · 0.95
Calls
1
setError
Method · 0.95
Tested by
no test coverage detected