(predicate func(*Event) bool)
| 401 | } |
| 402 | |
| 403 | func (e *inMemoryEvents) filter(predicate func(*Event) bool) []Event { |
| 404 | e.mu.RLock() |
| 405 | defer e.mu.RUnlock() |
| 406 | |
| 407 | var results []Event |
| 408 | for _, evt := range e.events { |
| 409 | if predicate(evt) { |
| 410 | results = append(results, *evt) |
| 411 | } |
| 412 | } |
| 413 | return results |
| 414 | } |
no outgoing calls
no test coverage detected