MCPcopy
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
191func 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

equalRecordsFunction · 0.70

Calls 2

ReadAllFunction · 0.70
CloseMethod · 0.45

Tested by

no test coverage detected