(promises []promise, requests []Request, merger protocol.Merger)
| 922 | } |
| 923 | |
| 924 | func join(promises []promise, requests []Request, merger protocol.Merger) promise { |
| 925 | return &joined{ |
| 926 | promises: promises, |
| 927 | requests: requests, |
| 928 | merger: merger, |
| 929 | } |
| 930 | } |
| 931 | |
| 932 | func (p *joined) await(ctx context.Context) (Response, error) { |
| 933 | results := make([]interface{}, len(p.promises)) |
no outgoing calls