DefaultKeyedAggregator reassembles replies in the exact key order of the original request.
| 764 | |
| 765 | // DefaultKeyedAggregator reassembles replies in the exact key order of the original request. |
| 766 | type DefaultKeyedAggregator struct { |
| 767 | mu sync.Mutex |
| 768 | results map[string]interface{} |
| 769 | keyOrder []string |
| 770 | firstErr error |
| 771 | } |
| 772 | |
| 773 | func NewDefaultKeyedAggregator(keyOrder []string) *DefaultKeyedAggregator { |
| 774 | return &DefaultKeyedAggregator{ |
nothing calls this directly
no outgoing calls
no test coverage detected