add WritePATPMT()
This commit is contained in:
parent
67ac6de4ed
commit
bfcfd605e6
24
muxer.go
24
muxer.go
@ -79,14 +79,7 @@ func (self *Muxer) WriteTrailer() (err error) {
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
func (self *Muxer) WriteHeader(streams []av.CodecData) (err error) {
|
func (self *Muxer) WritePATPMT() (err error) {
|
||||||
self.streams = []*Stream{}
|
|
||||||
for _, stream := range streams {
|
|
||||||
if err = self.newStream(stream); err != nil {
|
|
||||||
return
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
bufPAT := &bytes.Buffer{}
|
bufPAT := &bytes.Buffer{}
|
||||||
bufPMT := &bytes.Buffer{}
|
bufPMT := &bytes.Buffer{}
|
||||||
|
|
||||||
@ -131,6 +124,21 @@ func (self *Muxer) WriteHeader(streams []av.CodecData) (err error) {
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (self *Muxer) WriteHeader(streams []av.CodecData) (err error) {
|
||||||
|
self.streams = []*Stream{}
|
||||||
|
for _, stream := range streams {
|
||||||
|
if err = self.newStream(stream); err != nil {
|
||||||
|
return
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if err = self.WritePATPMT(); err != nil {
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
func (self *Muxer) WritePacket(streamIndex int, pkt av.Packet) (err error) {
|
func (self *Muxer) WritePacket(streamIndex int, pkt av.Packet) (err error) {
|
||||||
stream := self.streams[streamIndex]
|
stream := self.streams[streamIndex]
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user