fix: remove unnecssary threading

Bisonai · Aug 2, 2024 · 091eeaa · 091eeaa
1 parent ffb4cd2
commit 091eeaa
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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)
 		}