| 3228 | } |
| 3229 | |
| 3230 | type messageBatch struct { |
| 3231 | sync.Mutex |
| 3232 | msgs chan *Msg |
| 3233 | err error |
| 3234 | done chan struct{} |
| 3235 | } |
| 3236 | |
| 3237 | func (mb *messageBatch) Messages() <-chan *Msg { |
| 3238 | mb.Lock() |
nothing calls this directly
no outgoing calls
no test coverage detected