cleanup

flashbots · Jun 20, 2024 · be96643 · be96643
1 parent 31222c2
commit be96643
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/api/server.go b/api/server.go
@@ -106,14 +106,17 @@ func (s *Server) removeSubscriber(sub *SSESubscription) {
 }
 
 func (s *Server) SendTx(ctx context.Context, tx *common.TxIn) error {
-	s.log.Info("sending tx...")
+	s.sseConnectionLock.RLock()
+	defer s.sseConnectionLock.RUnlock()
+	if len(s.sseConnectionMap) == 0 {
+		return nil
+	}
+
 	txRLP, err := common.TxToRLPString(tx.Tx)
 	if err != nil {
 		return err
 	}
 
-	s.sseConnectionLock.RLock()
-	defer s.sseConnectionLock.RUnlock()
 	for _, sub := range s.sseConnectionMap {
 		sub.txC <- txRLP
 	}