From 091eeaa4b03b621269a2fc35b9d86da0dd18a6ab Mon Sep 17 00:00:00 2001 From: nick Date: Fri, 2 Aug 2024 14:52:26 +0900 Subject: [PATCH] fix: remove unnecssary 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 de0eb6bd7..1258ce2ac 100644 --- a/node/pkg/dal/api/hub.go +++ b/node/pkg/dal/api/hub.go @@ -127,7 +127,7 @@ func (c *Hub) castSubmissionData(data *dalcommon.OutgoingSubmissionData, symbol defer wg.Done() if err := entry.WriteJSON(*data); err != nil { log.Error().Err(err).Msg("failed to write message") - go func(entry *ThreadSafeClient) { c.unregister <- entry }(entry) + c.unregister <- entry } }(client) }