Go channel experiment

main.go

// Directory maps every file from a directory into an API model
func Directory(directory string) ([]models.API, error) {
	files, err := ioutil.ReadDir(directory)

	workerQueue := make(chan string)
	APImodelsChan := make(chan result)

	output := []models.API{}

	if err != nil {
		return output, err
	}

	go fileReader(workerQueue, APImodelsChan)

	for _, file := range files {
		path := filepath.Join(directory, file.Name())
		workerQueue <- path
	}
	close(workerQueue)

	for i:= 0; i< len(files); i++ {
		result := <- APImodelsChan
		if result.err != nil {
			return output, result.err
		} else {
			output = append(output, result.api)
		}
	}

	return output, nil
}

type result struct {
	api models.API
	err error
}

func fileReader(theFilePaths <- chan string, apis chan<- result) {
	for path := range theFilePaths {
		fmt.Println(path)
		api, err := File(path)

		go func () {
			apis <- result{api, err}
		}()
	}
}