PostGraphRequests function

gistfile1.go

func (api GraphV2) PostGraphRequests(urls []string) ([]BatchResponse, error) {
	batchCh := make(chan []BatchResponse)
	errs := make(chan error)
	responses := []BatchResponse{}

	var wg sync.WaitGroup
	for _, url := range urls {
		wg.Add(1)
		go func(url string) {
			defer wg.Done()

			resps, err := PostBatchFacebookGraphRequest(url)
			if err != nil {
				errs <- err
				return
			}
			batchCh <- resps
		}(url)
	}

	go func() {
		wg.Wait()
		close(batchCh)
	}()

	for resps := range batchCh {
		responses = append(responses, resps...)
	}

	select {
	case err := <-errs:
		return nil, err
	default:
		return responses, nil
	}
}