(do func(Logger))
| 1135 | } |
| 1136 | |
| 1137 | func (r *Reader) withErrorLogger(do func(Logger)) { |
| 1138 | if r.config.ErrorLogger != nil { |
| 1139 | do(r.config.ErrorLogger) |
| 1140 | } else { |
| 1141 | r.withLogger(do) |
| 1142 | } |
| 1143 | } |
| 1144 | |
| 1145 | func (r *Reader) activateReadLag() { |
| 1146 | if r.config.ReadLagInterval > 0 && atomic.CompareAndSwapUint32(&r.once, 0, 1) { |
no test coverage detected