Make debug backend forward on all messages

Docker-DCO-1.1-Signed-off-by: Ben Firshman <ben@firshman.co.uk> (github: bfirsh)

backends/backends.go

@@ -24,12 +24,21 @@ func New() *beam.Object {
 func Debug() beam.Sender {
 	backend := beam.NewServer()
 	backend.OnSpawn(beam.Handler(func(ctx *beam.Message) error {
-		instance := beam.NewServer()
+		instance := beam.Task(func(in beam.Receiver, out beam.Sender) {
-		instance.Catchall(beam.Handler(func(msg *beam.Message) error {
+			fmt.Printf("debug backend!")
-			fmt.Printf("[DEBUG] %s %s\n", msg.Verb, strings.Join(msg.Args, " "))
+			for {
-			ctx.Ret.Send(msg)
+				msg, err := in.Receive(beam.Ret)
-			return nil
+				if err != nil {
-		}))
+					fmt.Printf("debug receive: %v", err)
+					return
+				}
+				fmt.Printf("[DEBUG] %s %s\n", msg.Verb, strings.Join(msg.Args, " "))
+				if _, err := out.Send(msg); err != nil {
+					fmt.Printf("debug send: %v", err)
+					return
+				}
+			}
+		})
 		_, err := ctx.Ret.Send(&beam.Message{Verb: beam.Ack, Ret: instance})
 		return err
 	}))