修复bug，等待写入后才能获取type

Monibuca · Oct 1, 2020 · 9e626d8 · 9e626d8
1 parent 0bdd303
commit 9e626d8
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/subscriber.go b/subscriber.go
@@ -75,11 +75,12 @@ func (s *Subscriber) Subscribe(streamPath string) (err error) {
 		for atsent, dropping, droped := s.AudioTag==nil, false, 0; s.Err() == nil; packet.GoNext() {
 			s.TotalPacket++
 			if !dropping {
+				packet.Wait()
 				if !atsent && packet.Type == avformat.FLV_TAG_TYPE_AUDIO  {
 					s.sendAv(s.AudioTag, 0)
 					atsent = true
 				}
-				s.send(packet)
+				s.sendAv(&packet.AVPacket, packet.Timestamp-s.startTime)
 				if s.checkDrop(packet) {
 					dropping = true
 					droped = 0