Fix flv模式间断后的数据未保存 #80

diff --git a/Reply/stream.go b/Reply/stream.go
index 196c8275c92370b72f26c50fd266681a2e2f1b61..05d9825831c8e05cd2ba60c483e5070e1e24d840 100644 (file)
--- a/Reply/stream.go
+++ b/Reply/stream.go
@@ -801,7 +801,6 @@ func (t *M4SStream) saveStreamFlv() (e error) {
                                buff.Reset()
 
                                ticker.Stop()
-                               t.Stream_msg.PushLock_tag(`close`, nil)
                        }()
 
                        t.log.L(`I: `, `flv下载开始`)
@@ -839,6 +838,7 @@ func (t *M4SStream) saveStreamFlv() (e error) {
                }
                cancel()
                t.reqPool.Put(r)
+               t.Stream_msg.PushLock_tag(`close`, nil)
        }
 }