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

Function dontExpectEOF

protocol/protocol.go:403–413  ·  view source on GitHub ↗
(err error)

Source from the content-addressed store, hash-verified

401}
402
403func dontExpectEOF(err error) error {
404 if err != nil {
405 if errors.Is(err, io.EOF) {
406 return io.ErrUnexpectedEOF
407 }
408
409 return err
410 }
411
412 return nil
413}
414
415type Broker struct {
416 Rack string

Callers 5

ReadFromMethod · 0.70
readMessageFunction · 0.70
ReadRequestFunction · 0.70
UnmarshalFunction · 0.70
ReadResponseFunction · 0.70

Calls

no outgoing calls

Tested by

no test coverage detected