Initial commit

Author: roshangade

async.go

@@ -6,26 +6,35 @@
 package async
 
 type Task func() interface{}
-type Result chan interface{}
+type Channel chan interface{}
+type Result []interface{}
+type Out interface{}
 
 type Promise struct {
 	//TODO:
 	//Context - Cancel, Timeout
 	//Concurrency vs Parallelism
 	//What to do on error? Is it best way to abort all operation?
+	//Can I use map for tasks? It will be easy to associate results with keys
 }
 
-func (p *Promise) All(tasks []Task) []Result {
-	workers := make([]Result, 0, len(tasks))
+func (p *Promise) All(tasks []Task) Result {
+	workers := make([]Channel, 0, len(tasks))
 	for _, task := range tasks {
 		result := execute(task)
 		workers = append(workers, result)
 	}
-	return workers
+
+	// gather data from all channels
+	out := make(Result, 0, len(tasks))
+	for _, a := range workers {
+		out = append(out, <-a)
+	}
+	return out
 }
 
-func execute(task Task) Result {
-	out := make(Result)
+func execute(task Task) Channel {
+	out := make(Channel)
 	{
 		go func() {
 			defer close(out)

examples/main.go

@@ -22,10 +22,9 @@ func main() {
 		},
 	}
 
-	for _, a := range promise.All(tasks) {
-		// switch statement for results
-		fmt.Println(<-a)
-	}
+	result := promise.All(tasks)
+
+	fmt.Println("Result: ", result)
 
 	fmt.Println("exit")
 }