rewrite pat and pmt

pull/267/head
ZSC714725 2 years ago
parent e87a1979cc
commit 3995701869

@ -90,7 +90,7 @@ func (q *rtmp2MpegtsFilter) Push(msg base.RtmpMsg) {
func (q *rtmp2MpegtsFilter) drain() { func (q *rtmp2MpegtsFilter) drain() {
videoType := q.getVideoStreamType() videoType := q.getVideoStreamType()
audioType := q.getVideoStreamType() audioType := q.getAudioStreamType()
patpmt := mpegts.WritePat() patpmt := mpegts.WritePat()
patpmt = append(patpmt, mpegts.WritePmt(videoType, audioType)...) patpmt = append(patpmt, mpegts.WritePmt(videoType, audioType)...)
q.observer.onPatPmt(patpmt) q.observer.onPatPmt(patpmt)

Loading…
Cancel
Save