(key string, result interface{}, err error)
| 815 | } |
| 816 | |
| 817 | func (a *DefaultKeyedAggregator) addWithKey(key string, result interface{}, err error) error { |
| 818 | if err != nil && a.firstErr == nil { |
| 819 | a.firstErr = err |
| 820 | return nil |
| 821 | } |
| 822 | if err == nil { |
| 823 | a.results[key] = result |
| 824 | } |
| 825 | return nil |
| 826 | } |
| 827 | |
| 828 | func (a *DefaultKeyedAggregator) AddWithKey(key string, result interface{}, err error) error { |
| 829 | a.mu.Lock() |
no outgoing calls
no test coverage detected