优化代码

src/Common/MediaSource.h

@@ -158,6 +158,14 @@ public:
         }
         return listener->close(*this,force);
     }
+
+    void onNoneReader(){
+        auto listener = _listener.lock();
+        if(!listener){
+            return;
+        }
+        listener->onNoneReader(*this);
+    }
     virtual void setListener(const std::weak_ptr<MediaSourceEvent> &listener){
         _listener = listener;
     }

src/Rtmp/RtmpMediaSource.h

@@ -141,11 +141,7 @@ private:
         GET_CONFIG(int,stream_none_reader_delay,General::kStreamNoneReaderDelayMS);
         if(_asyncEmitNoneReader && _readerTicker.elapsedTime() > stream_none_reader_delay){
             _asyncEmitNoneReader = false;
-            auto listener = _listener.lock();
-            if(!listener){
-                return;
-            }
-            listener->onNoneReader(*this);
+            onNoneReader();
         }
     }
 protected:

src/Rtsp/RtspMediaSource.h

@@ -162,11 +162,7 @@ private:
         GET_CONFIG(int,stream_none_reader_delay,General::kStreamNoneReaderDelayMS);
         if(_asyncEmitNoneReader && _readerTicker.elapsedTime() > stream_none_reader_delay){
             _asyncEmitNoneReader = false;
-            auto listener = _listener.lock();
-            if(!listener){
-                return;
-            }
-            listener->onNoneReader(*this);
+            onNoneReader();
         }
 	}
 protected: