Apply suggestions from code review

Co-authored-by: Emilia Hane <elsaemiliaevahane@gmail.com>

crates/net/network/src/network.rs

@@ -440,7 +440,7 @@ pub(crate) enum NetworkHandleMessage {
     /// Disconnects a connection to a peer if it exists, optionally providing a disconnect reason.
     DisconnectPeer(PeerId, Option<DisconnectReason>),
     /// Adds a new listener for `NetworkEvent`.
-    EventListener(Sender<NetworkEvent>),
+    EventListener(broadcast::Sender<NetworkEvent>),
     /// Broadcasts an event to announce a new block to all nodes.
     AnnounceBlock(NewBlock, B256),
     /// Sends a list of transactions to the given peer.

crates/rpc/rpc-builder/tests/it/utils.rs

@@ -27,8 +27,7 @@ pub fn test_address() -> SocketAddr {
 pub async fn launch_auth(secret: JwtSecret) -> AuthServerHandle {
     let config = AuthServerConfig::builder(secret).socket_addr(test_address()).build();
     let (tx, _rx) = unbounded_channel();
-    let listeners: EventListeners<BeaconConsensusEngineEvent> = Default::default();
-    let beacon_engine_handle = BeaconConsensusEngineHandle::<EthEngineTypes>::new(tx, listeners);
+    let beacon_engine_handle = BeaconConsensusEngineHandle::<EthEngineTypes>::new(tx, Default::default());
     let engine_api = EngineApi::new(
         NoopProvider::default(),
         MAINNET.clone(),

crates/tokio-util/src/event_listeners.rs

@@ -2,7 +2,7 @@ use tokio::sync::broadcast::{self, Sender};
 use tokio_stream::wrappers::BroadcastStream;
 use tracing::{error, warn};
 
-const DEFAULT_BROADCAST_CHANNEL_SIZE: usize = 1000;
+const DEFAULT_SIZE_BROADCAST_CHANNEL: usize = 1000;
 
 /// A bounded broadcast channel for a task.
 #[derive(Debug)]