gwuhaolin#112 issue improved, stopping writing to flvs after streamin…

…g stopped
nickoo123 · Dec 7, 2020 · fa892e2 · fa892e2
1 parent 4d921fa
commit fa892e2
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/protocol/rtmp/stream.go b/protocol/rtmp/stream.go
@@ -402,8 +402,8 @@ func (s *Stream) closeInter() {
 	s.ws.Range(func(key, val interface{}) bool {
 		v := val.(*PackWriterCloser)
 		if v.w != nil {
+			v.w.Close(fmt.Errorf("closed"))
 			if v.w.Info().IsInterval() {
-				v.w.Close(fmt.Errorf("closed"))
 				s.ws.Delete(key)
 				log.Debugf("[%v] player closed and remove\n", v.w.Info())
 			}