diff --git a/client.go b/client.go index c9b860d..658253d 100644 --- a/client.go +++ b/client.go @@ -127,7 +127,6 @@ func (p *RTSPPusher) Connect() error { func (p *RTSPPusher) Push() (err error) { var u *url.URL u, err = url.Parse(p.RemoteURL) - defer p.Stop() // startTime := time.Now() // for len(p.tracks) < 2 { // if time.Sleep(time.Second); time.Since(startTime) > time.Second*10 { diff --git a/publisher.go b/publisher.go index 3a08719..b0f0b14 100644 --- a/publisher.go +++ b/publisher.go @@ -51,6 +51,8 @@ func (p *RTSPPublisher) SetTracks() error { case *format.MPEG4Audio: at := NewAAC(p.Stream, f.PayloadType(), uint32(f.Config.SampleRate)) p.Tracks[track] = at + at.IndexDeltaLength = f.IndexDeltaLength + at.IndexLength = f.IndexLength at.SizeLength = f.SizeLength if f.Config.Type == mpeg4audio.ObjectTypeAACLC { at.Mode = 1 diff --git a/subscriber.go b/subscriber.go index ee00bbb..a2baa61 100644 --- a/subscriber.go +++ b/subscriber.go @@ -63,9 +63,9 @@ func (s *RTSPSubscriber) OnEvent(event any) { SampleRate: int(v.SampleRate), ChannelCount: int(v.Channels), }, - SizeLength: 13, - IndexLength: 3, - IndexDeltaLength: 3, + SizeLength: v.SizeLength, + IndexLength: v.IndexLength, + IndexDeltaLength: v.IndexDeltaLength, }}, } s.audioTrack = audio