feat: eventbus 减少不必要的clone次数

Author: nintha

resource/static/index.html

@@ -6,8 +6,8 @@
         var videoElement = document.getElementById('videoElement');
         videoElement.controls=true
         videoElement.muted=true
-        videoElement.width="640"
-        videoElement.height="480"
+        videoElement.width="960"
+        videoElement.height="540"
         videoElement.autoplay=true
 
         var flvPlayer = flvjs.createPlayer({

src/eventbus.rs

@@ -20,7 +20,8 @@ impl<E: 'static + Clone> EventBus<E> {
     pub async fn publish(&self, val: E) {
         let mut dropped_senders: Vec<u64> = vec![];
 
-        let keys: Vec<u64> = self.tx_map.iter().map(|x| x.key().to_owned()).collect();
+        let mut keys: Vec<u64> = self.tx_map.iter().map(|x| x.key().to_owned()).collect();
+        let last_key = keys.pop();
 
         for key in keys {
             if let Some(entry) = self.tx_map.get(&key) {
@@ -29,6 +30,15 @@ impl<E: 'static + Clone> EventBus<E> {
                 }
             }
         }
+        // 最后一个元素可以直接发送，减少一次clone
+        if let Some(key) = last_key {
+            if let Some(entry) = self.tx_map.get(&key) {
+                if let Err(_) = entry.send(val).await {
+                    dropped_senders.push(key);
+                }
+            }
+        }
+
         for key in dropped_senders.iter() {
             self.tx_map.remove(key);
             log::info!("[EventBus][{}] remove receiver {}", self.label, key);

src/rtmp_server.rs

@@ -8,7 +8,6 @@ use smol::net::{TcpListener, TcpStream};
 use smol::prelude::*;
 
 use crate::eventbus::EventBus;
-use crate::protocol::flv::save_flv_background;
 use crate::protocol::rtmp::{
     ChunkMessageType, Handshake0, Handshake1, Handshake2, RtmpContext, RtmpMessage, RtmpMetaData,
 };
@@ -191,7 +190,6 @@ async fn connection_loop(stream: TcpStream) -> anyhow::Result<()> {
                             EventBus::with_label(ctx.stream_name.clone()),
                         );
                         ctx.is_publisher = true;
-                        save_flv_background(&ctx.stream_name, ctx.peer_addr.clone());
                         response_publish(&mut ctx).await?;
                     }
                     "play" => {