Simultaneous RPC during events retrieval pipeline

Cerebellum-Network · Sep 16, 2024 · 8071fc0 · 8071fc0
1 parent 18877e7
commit 8071fc0
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/blockchain/client.go b/blockchain/client.go
@@ -128,7 +128,7 @@ func (c *Client) ListenEvents(
 	})
 
 	// Sequence historical and live headers.
-	headersC := make(chan types.Header)
+	headersC := make(chan types.Header, 2)
 	g.Go(func() error {
 		defer close(headersC)
 
@@ -152,7 +152,7 @@ func (c *Client) ListenEvents(
 	})
 
 	// Retrieve events skipping blocks before 'begin'.
-	eventsC := make(chan blockEvents)
+	eventsC := make(chan blockEvents, 2)
 	g.Go(func() error {
 		defer close(eventsC)