gistfile1.txt

package checker

import (
	"github.com/davecgh/go-spew/spew"
	"github.com/ronpastore/pricing/pkg/sources"
	"github.com/ronpastore/pricing/pkg/core"
	"sync"
)

func CheckAll() []core.PriceResult {
	var waitGroup sync.WaitGroup
	sources := []core.Source{
		sources.DummySource{},
		sources.AmazonSource{},
	}

	waitGroup.Add(len(sources))
	resultChan := make(chan core.PriceResult, len(sources))

	for _, entry := range sources {
		go func(source core.Source) {
			defer waitGroup.Done()
			priceResult := source.Check()
			resultChan <- priceResult
		}(entry)
	}

	waitGroup.Wait()
	close(resultChan)
	results := toSlice(resultChan)
	spew.Dump(results)

	return results
}

func toSlice(c chan core.PriceResult) []core.PriceResult {
    s := make([]core.PriceResult, 0)
    for i := range c {
        s = append(s, i)
    }
    return s
}