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

Method ReadFrom

protocol/buffer.go:153–160  ·  view source on GitHub ↗
(r io.Reader)

Source from the content-addressed store, hash-verified

151}
152
153func (p *page) ReadFrom(r io.Reader) (int64, error) {
154 n, err := io.ReadFull(r, p.buffer[p.length:])
155 if errors.Is(err, io.EOF) || errors.Is(err, io.ErrUnexpectedEOF) {
156 err = nil
157 }
158 p.length += n
159 return int64(n), err
160}
161
162func (p *page) WriteAt(b []byte, off int64) (int, error) {
163 if off -= p.offset; off < 0 || off > pageSize {

Callers 5

readMessageV1Method · 0.45
readMessageV2Method · 0.45
ReadFromMethod · 0.45
readerDecodeFuncOfFunction · 0.45
readFromVersion2Method · 0.45

Calls

no outgoing calls

Tested by

no test coverage detected