Code
Hub
Workspaces
Connect
Indexed graphs
Engine
MCP
copy
hub
/
github.com/segmentio/kafka-go
/ readAll
Function
readAll
protocol/record_batch_test.go:191–200 ·
view source on GitHub ↗
(bytes Bytes)
Source
from the content-addressed store, hash-verified
189
}
190
191
func
readAll(bytes Bytes) []byte {
192
if
bytes != nil {
193
defer
bytes.Close()
194
}
195
b, err := ReadAll(bytes)
196
if
err != nil {
197
panic(err)
198
}
199
return
b
200
}
Callers
1
equalRecords
Function · 0.70
Calls
2
ReadAll
Function · 0.70
Close
Method · 0.45
Tested by
no test coverage detected