From f1be0f12966b357474b260166482a3892a192601 Mon Sep 17 00:00:00 2001
From: vyzo <vyzo@hackzen.org>
Date: Sat, 13 Jan 2018 22:14:01 +0200
Subject: [PATCH] don't spawn an extra goroutine for the validator context

---
 subscription.go | 19 +++++--------------
 1 file changed, 5 insertions(+), 14 deletions(-)

diff --git a/subscription.go b/subscription.go
index 3aa51c8..a15466a 100644
--- a/subscription.go
+++ b/subscription.go
@@ -38,22 +38,13 @@ func (sub *Subscription) Cancel() {
 }
 
 func (sub *Subscription) validateMsg(ctx context.Context, msg *Message) bool {
-	result := make(chan bool, 1)
 	vctx, cancel := context.WithTimeout(ctx, sub.validateTimeout)
 	defer cancel()
 
-	go func() {
-		result <- sub.validate(vctx, msg)
-	}()
-
-	select {
-	case valid := <-result:
-		if !valid {
-			log.Debugf("validation failed for topic %s", sub.topic)
-		}
-		return valid
-	case <-vctx.Done():
-		log.Debugf("validation timeout for topic %s", sub.topic)
-		return false
+	valid := sub.validate(vctx, msg)
+	if !valid {
+		log.Debugf("validation failed for topic %s", sub.topic)
 	}
+
+	return valid
 }