MCPcopy
hub / github.com/segmentio/kafka-go / readAll

Function readAll

protocol/prototest/reflect.go:141–150  ·  view source on GitHub ↗
(bytes protocol.Bytes)

Source from the content-addressed store, hash-verified

139}
140
141func readAll(bytes protocol.Bytes) []byte {
142 if bytes != nil {
143 defer bytes.Close()
144 }
145 b, err := protocol.ReadAll(bytes)
146 if err != nil {
147 panic(err)
148 }
149 return b
150}

Callers 1

loadRecordsFunction · 0.70

Calls 2

ReadAllFunction · 0.92
CloseMethod · 0.45

Tested by

no test coverage detected