diff --git a/pkg/server/server.go b/pkg/server/server.go
index 86b1eaf1c2c73543d8111cc80d42a5a18d40cb00..59d5af4ce852ea986a028b571e9ef310c3bacfdf 100644
--- a/pkg/server/server.go
+++ b/pkg/server/server.go
@@ -60,11 +60,9 @@ func ServeCodec(ctx context.Context, remote jsonrpc.ReaderWriter, handler jsonrp
 			}
 		}
 	}()
-	wg := sync.WaitGroup{}
 	// this errgroup controls the max concurrent requests per codec
 	for batch := range batches {
 		incoming, batch := batch.Messages, batch.Batch
-		wg.Add(1)
 		responder := &callResponder{
 			peerinfo: remote.PeerInfo(),
 			batch:    batch,