sse api: skip sending to subscriber if queue is full

flashbots · Jun 24, 2024 · fb9da19 · fb9da19
1 parent 5567b87
commit fb9da19
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/api/server.go b/api/server.go
@@ -50,7 +50,6 @@ func New(cfg *HTTPServerConfig) (srv *Server) {
 	mux := chi.NewRouter()
 
 	mux.With(srv.httpLogger).Get("/sse/transactions", srv.handleTxSSE)
-	// mux.With(srv.httpLogger).Get("/sse/dummyTx", srv.handleDummyTx)
 
 	if cfg.EnablePprof {
 		srv.log.Info("pprof API enabled")
@@ -117,8 +116,12 @@ func (s *Server) SendTx(ctx context.Context, tx *common.TxIn) error {
 		return err
 	}
 
+	// Send tx to all subscribers (only if channel is not full)
 	for _, sub := range s.sseConnectionMap {
-		sub.txC <- txRLP
+		select {
+		case sub.txC <- txRLP:
+		default:
+		}
 	}
 
 	return nil