diff --git a/pubsub_test.go b/pubsub_test.go
index 94906883..ba26be7b 100644
--- a/pubsub_test.go
+++ b/pubsub_test.go
@@ -347,11 +347,11 @@ var _ = Describe("PubSub", func() {
 			defer GinkgoRecover()
 
 			wg.Done()
-
+			defer wg.Done()
+			
 			_, err := pubsub.ReceiveMessage()
 			Expect(err).To(MatchError("redis: client is closed"))
 
-			wg.Done()
 		}()
 
 		wg.Wait()