增加读取缓存大小，设置Mark标志位

client.go

@@ -145,12 +145,14 @@ func (client *RTSPClient) pullStream() {
 	}
 	client.Client = &gortsplib.Client{
 		OnPacketRTP: func(trackID int, payload []byte) {
+			// Println("OnPacketRTP", trackID, len(payload))
 			if f := client.processFunc[trackID]; f != nil {
 				var clone []byte
 				f(append(clone, payload...))
 			}
 		},
-		Transport: &client.Transport,
+		ReadBufferSize: 10000,
+		Transport:      &client.Transport,
 	}
 	// parse URL
 	u, err := base.ParseURL(client.URL)

server.go

@@ -97,9 +97,10 @@ func (sh *RTSPServer) OnDescribe(ctx *gortsplib.ServerHandlerOnDescribeCtx) (*ba
 			}
 			var st uint32
 			onVideo := func(ts uint32, pack *engine.VideoPack) {
-				for _, nalu := range pack.NALUs {
-					for _, pack := range vpacketer.Packetize(nalu, (ts-st)*90) {
-						rtp, _ := pack.Marshal()
+				for i, nalu := range pack.NALUs {
+					for _, rtpack := range vpacketer.Packetize(nalu, (ts-st)*90) {
+						rtpack.Marker = i == len(pack.NALUs)-1
+						rtp, _ := rtpack.Marshal()
 						stream.WritePacketRTP(trackId, rtp)
 					}
 				}