From a9601844b227a82aa4ace46e493aa6d67b8dfc7d Mon Sep 17 00:00:00 2001
From: dexter <178529795@qq.com>
Date: Thu, 2 Feb 2023 12:09:10 +0800
Subject: [PATCH] =?UTF-8?q?=E9=80=82=E9=85=8D=E5=BC=95=E6=93=8E=E7=9A=84?=
 =?UTF-8?q?=E5=8D=87=E7=BA=A7?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 subscriber.go | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/subscriber.go b/subscriber.go
index b83309e..7752367 100644
--- a/subscriber.go
+++ b/subscriber.go
@@ -82,17 +82,17 @@ func (suber *WebRTCSubscriber) OnEvent(event any) {
 				suber.flvHeadCache[0] = 9
 				suber.DC.Send(codec.FLVHeader)
 			}
-			suber.DC.Send(util.ConcatBuffers(codec.VideoAVCC2FLV(v.AVCC, 0)))
+			suber.DC.Send(util.ConcatBuffers(codec.VideoAVCC2FLV(0, v)))
 		}
 	case VideoRTP:
 		if suber.videoTrack != nil {
 			suber.videoTrack.WriteRTP(&v.Packet)
 		} else if suber.DC != nil {
-			frame := suber.Video.Frame
-			dataSize := uint32(util.SizeOfBuffers(frame.AVCC))
+			frame := suber.VideoReader.Frame
+			dataSize := uint32(frame.AVCC.ByteLength)
 			result := net.Buffers{suber.flvHeadCache[:11]}
-			result = append(result, frame.AVCC...)
-			ts := frame.AbsTime - suber.SkipTS
+			result = append(result, frame.AVCC.ToBuffers()...)
+			ts := suber.VideoReader.AbsTime
 			util.PutBE(suber.flvHeadCache[1:4], dataSize)
 			util.PutBE(suber.flvHeadCache[4:7], ts)
 			suber.flvHeadCache[7] = byte(ts >> 24)