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

Struct emptyRecordReader

protocol/record_batch.go:164–164  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

162}
163
164type emptyRecordReader struct{}
165
166func (emptyRecordReader) ReadRecord() (*Record, error) { return nil, io.EOF }
167

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected