apps/plugin-rtsp
1
0
Fork 0
mirror of https://github.com/Monibuca/plugin-rtsp.git synced 2025-09-27 03:56:08 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

优化代码

Browse Source
This commit is contained in:
dexter
2022-04-24 09:55:37 +08:00
parent c7c8858d36
commit 7d0451c204
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
subscriber.go
View File

@@ -29,6 +29,7 @@ func (s *RTSPSubscriber) OnEvent(event any) {
s.tracks = append(s.tracks, vtrack) s.tracks = append(s.tracks, vtrack)
} }
} }
s.AddTrack(v)
case *track.Audio: case *track.Audio:
switch v.CodecID { switch v.CodecID {
case codec.CodecID_AAC: case codec.CodecID_AAC:
@@ -45,6 +46,7 @@ func (s *RTSPSubscriber) OnEvent(event any) {
s.audioTrackId = len(s.tracks) s.audioTrackId = len(s.tracks)
s.tracks = append(s.tracks, gortsplib.NewTrackPCMU()) s.tracks = append(s.tracks, gortsplib.NewTrackPCMU())
} }
s.AddTrack(v)
case ISubscriber: case ISubscriber:
s.stream = gortsplib.NewServerStream(s.tracks) s.stream = gortsplib.NewServerStream(s.tracks)
case *AudioFrame: case *AudioFrame:
@@ -55,6 +57,7 @@ func (s *RTSPSubscriber) OnEvent(event any) {
for _, pack := range v.RTP { for _, pack := range v.RTP {
s.stream.WritePacketRTP(s.videoTrackId, &pack.Packet) s.stream.WritePacketRTP(s.videoTrackId, &pack.Packet)
} }
default:
s.Subscriber.OnEvent(event)
} }
s.Subscriber.OnEvent(event)
} }