Method ReadPES

publisher-ts.go:77–111

()

}

func (t *TSReader) ReadPES() {
	for pes := range t.PESChan {
		if t.Err() != nil {
			continue
		}
		if pes.Header.Dts == 0 {
			pes.Header.Dts = pes.Header.Pts
		}
		switch pes.Header.StreamID & 0xF0 {
		case mpegts.STREAM_ID_VIDEO:
			if t.VideoTrack == nil {
				for _, s := range t.PMT.Stream {
					t.OnPmtStream(s)
				}
			}
			if t.VideoTrack != nil {
				t.WriteAnnexB(uint32(pes.Header.Pts), uint32(pes.Header.Dts), pes.Payload)
			}
		default:
			if t.AudioTrack == nil {
				for _, s := range t.PMT.Stream {
					t.OnPmtStream(s)
				}
			}
			if t.AudioTrack != nil {
				switch t.AudioTrack.(type) {
				case *track.AAC:
					t.AudioTrack.WriteADTS(uint32(pes.Header.Pts), pes.Payload)
				case *track.G711:
					t.AudioTrack.WriteRawBytes(uint32(pes.Header.Pts), pes.Payload)
				}
			}
		}
	}
}