From eff66e664fa31db87c9b62f329a0f607a6ef4ea0 Mon Sep 17 00:00:00 2001
From: James Milligan <james@omnant.co.uk>
Date: Wed, 1 Feb 2023 14:47:34 +0000
Subject: [PATCH] buffer channel to prevent blocking

Signed-off-by: James Milligan <james@omnant.co.uk>
---
 pkg/runtime/runtime.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/pkg/runtime/runtime.go b/pkg/runtime/runtime.go
index 41b468c68..3c441a0ee 100644
--- a/pkg/runtime/runtime.go
+++ b/pkg/runtime/runtime.go
@@ -55,7 +55,7 @@ func (r *Runtime) Start() error {
 	defer cancel()
 
 	g, gCtx := errgroup.WithContext(ctx)
-	dataSync := make(chan sync.DataSync)
+	dataSync := make(chan sync.DataSync, len(r.SyncImpl))
 
 	// Initialize DataSync channel watcher
 	g.Go(func() error {