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

Method readNewString

message_reader.go:500–503  ·  view source on GitHub ↗
(len int)

Source from the content-addressed store, hash-verified

498}
499
500func (r *messageSetReader) readNewString(len int) (res string, err error) {
501 res, r.remain, err = readNewString(r.reader, r.remain, len)
502 return
503}
504
505func (r *messageSetReader) readInt8(val *int8) (err error) {
506 r.remain, err = readInt8(r.reader, r.remain, val)

Callers 1

readMessageHeaderMethod · 0.95

Calls 1

readNewStringFunction · 0.85

Tested by

no test coverage detected