From 7f9eb626408434599c33663b160994029d887bb3 Mon Sep 17 00:00:00 2001
From: Christian Schwarz <me@cschwarz.com>
Date: Tue, 18 Sep 2018 22:44:00 +0200
Subject: [PATCH] sink: concurrent connection handling

---
 daemon/job/sink.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/daemon/job/sink.go b/daemon/job/sink.go
index 18c009c..627b999 100644
--- a/daemon/job/sink.go
+++ b/daemon/job/sink.go
@@ -76,7 +76,7 @@ outer:
 			connId++
 			connLog := log.
 				WithField("connID", connId)
-			j.handleConnection(WithLogger(ctx, connLog), res.conn)
+			go j.handleConnection(WithLogger(ctx, connLog), res.conn)
 
 		case <-ctx.Done():
 			break outer