diff --git a/format/ts/muxer.go b/format/ts/muxer.go index 53bc6a0..faea462 100644 --- a/format/ts/muxer.go +++ b/format/ts/muxer.go @@ -172,7 +172,8 @@ func (self *Muxer) WritePacket(pkt av.Packet) (err error) { stream, ok := self.streams[int(pkt.Idx)] if !ok { fmt.Printf("Warning, unsupported stream index: %d\n", pkt.Idx) - return + err = fmt.Errorf("Warning, unsupported stream index: %d", pkt.Idx) + return err } pkt.Time += time.Second