From 383479f4ad81b11c4a82afe68ff0db92dbc415ba Mon Sep 17 00:00:00 2001 From: nick Date: Mon, 29 Jul 2024 17:49:58 +0900 Subject: [PATCH] feat: add missing threading --- node/pkg/dal/api/hub.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/node/pkg/dal/api/hub.go b/node/pkg/dal/api/hub.go index ac1c35f5c..c732b185c 100644 --- a/node/pkg/dal/api/hub.go +++ b/node/pkg/dal/api/hub.go @@ -99,7 +99,7 @@ func (c *Hub) configIdToSymbol(id int32) string { func (c *Hub) broadcastDataForSymbol(symbol string) { for data := range c.broadcast[symbol] { - c.castSubmissionData(&data, &symbol) + go c.castSubmissionData(&data, &symbol) } }