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

Method withErrorLogger

reader.go:1575–1581  ·  view source on GitHub ↗
(do func(Logger))

Source from the content-addressed store, hash-verified

1573}
1574
1575func (r *reader) withErrorLogger(do func(Logger)) {
1576 if r.errorLogger != nil {
1577 do(r.errorLogger)
1578 } else {
1579 r.withLogger(do)
1580 }
1581}
1582
1583// extractTopics returns the unique list of topics represented by the set of
1584// provided members.

Callers 1

runMethod · 0.95

Calls 1

withLoggerMethod · 0.95

Tested by

no test coverage detected