Commit eabb6730 by xiongziliang

无人观看延时关闭

parent 5b88057a
...@@ -127,9 +127,9 @@ public: ...@@ -127,9 +127,9 @@ public:
private: private:
void onReaderChanged(int size){ void onReaderChanged(int size){
_readerTicker.resetTime();
if(size != 0 || readerCount() != 0){ if(size != 0 || readerCount() != 0){
//还有消费者正在观看该流,我们记录最后一次活动时间 //还有消费者正在观看该流,我们记录最后一次活动时间
_readerTicker.resetTime();
_asyncEmitNoneReader = false; _asyncEmitNoneReader = false;
return; return;
} }
......
...@@ -143,9 +143,9 @@ public: ...@@ -143,9 +143,9 @@ public:
} }
private: private:
void onReaderChanged(int size){ void onReaderChanged(int size){
_readerTicker.resetTime();
if(size != 0 || readerCount() != 0){ if(size != 0 || readerCount() != 0){
//还有消费者正在观看该流,我们记录最后一次活动时间 //还有消费者正在观看该流,我们记录最后一次活动时间
_readerTicker.resetTime();
_asyncEmitNoneReader = false; _asyncEmitNoneReader = false;
return; return;
} }
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论