Sarthak | WorkerGroup now establishes a new connection even if the ex…

…isting connection is nil
SarthakMakhija · Aug 18, 2023 · fb76ae5 · fb76ae5
1 parent 53a2a47
commit fb76ae5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/workers/worker_group.go b/workers/worker_group.go
@@ -64,7 +64,7 @@ func (group *WorkerGroup) runWorkers(
 
 	var connection net.Conn
 	for count := 0; count < int(group.options.concurrency); count++ {
-		if count%int(connectionsSharedByWorker) == 0 {
+		if count%int(connectionsSharedByWorker) == 0 || connection == nil {
 			connection, _ = group.newConnection()
 			// TODO: Handle error
 			if group.responseReader != nil && connection != nil {