pool.go

// Collect post processes the channel "Results" and calls the ResultProcessorFunc passed in as reference
// for further processing.
func (m *Pool) collect(proc ResultProcessorFunc) {
	log.DEBUG.Print("goRoutine collect starting")
	for result := range m.results {
		outcome := proc(result)
		log.DEBUG.Printf("Job with id: [%d] completed, outcome: %s", result.Job.id, outcome)
	}
	log.DEBUG.Print("goRoutine collect done, setting channel done as completed")
	m.done <- true
	m.completed = true
}