diff --git a/pkg/remux/rtmp2mpegts_filter_.go b/pkg/remux/rtmp2mpegts_filter_.go index 16fd41a..6bec77d 100644 --- a/pkg/remux/rtmp2mpegts_filter_.go +++ b/pkg/remux/rtmp2mpegts_filter_.go @@ -90,7 +90,7 @@ func (q *rtmp2MpegtsFilter) Push(msg base.RtmpMsg) { func (q *rtmp2MpegtsFilter) drain() { videoType := q.getVideoStreamType() - audioType := q.getVideoStreamType() + audioType := q.getAudioStreamType() patpmt := mpegts.WritePat() patpmt = append(patpmt, mpegts.WritePmt(videoType, audioType)...) q.observer.onPatPmt(patpmt)