From 75b1e228cce0282b3406ee0614ac169b2eaf149d Mon Sep 17 00:00:00 2001
From: Aanand Prasad <aanand.prasad@gmail.com>
Date: Wed, 4 Jun 2014 13:25:03 -0700
Subject: [PATCH] Remove extra goroutine wrapper in task.go

Signed-off-by: Aanand Prasad <aanand.prasad@gmail.com>
Signed-off-by: Ben Firshman <ben@firshman.co.uk>
Signed-off-by: Solomon Hykes <solomon@docker.com>
---
 beam/task.go | 9 +++------
 1 file changed, 3 insertions(+), 6 deletions(-)

diff --git a/beam/task.go b/beam/task.go
index 57a8d2c411..0ceaec7ce4 100644
--- a/beam/task.go
+++ b/beam/task.go
@@ -13,12 +13,9 @@ func Task(f func(in Receiver, out Sender)) Sender {
 	obj := NewServer()
 	obj.OnAttach(Handler(func(msg *Message) error {
 		msg.Ret.Send(&Message{Name: "ack", Ret: inW})
-		go func() {
-			fmt.Printf("copying task output from %#v to %#v\n", outR, msg.Ret)
-			defer fmt.Printf("(DONE) copying task output from %#v to %#v\n", outR, msg.Ret)
-			Copy(msg.Ret, outR)
-			msg.Ret.Close()
-		}()
+		fmt.Printf("copying task output from %#v to %#v\n", outR, msg.Ret)
+		defer fmt.Printf("(DONE) copying task output from %#v to %#v\n", outR, msg.Ret)
+		Copy(msg.Ret, outR)
 		return nil
 	}))
 	obj.OnStart(Handler(func(msg *Message) error {