From 60e0221c3dc6839d4b9372c31b23b66ed58cee80 Mon Sep 17 00:00:00 2001
From: Dimitrij Denissenko <dimitrij.denissenko@blacksquaremedia.com>
Date: Fri, 17 Apr 2015 14:03:34 +0100
Subject: [PATCH] Handle test failures

---
 pipeline_test.go | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/pipeline_test.go b/pipeline_test.go
index 9d2770d6..d250d457 100644
--- a/pipeline_test.go
+++ b/pipeline_test.go
@@ -123,6 +123,9 @@ var _ = Describe("Pipelining", func() {
 		wg.Add(N)
 		for i := 0; i < N; i++ {
 			go func(i int) {
+				defer GinkgoRecover()
+				defer wg.Done()
+
 				pipeline := client.Pipeline()
 
 				msg1 := "echo" + strconv.Itoa(i)
@@ -142,8 +145,6 @@ var _ = Describe("Pipelining", func() {
 				Expect(echo2.Val()).To(Equal(msg2))
 
 				Expect(pipeline.Close()).NotTo(HaveOccurred())
-
-				wg.Done()
 			}(i)
 		}
 		wg.Wait()