rename stream.onPacketRTP/RTCP into stream.writePacketRTP/RTCP

This commit is contained in:
aler9
2022-03-15 12:44:01 +01:00
parent e611c7ddfd
commit 28063a1fbe
7 changed files with 22 additions and 22 deletions

View File

@@ -162,12 +162,12 @@ func (s *rtmpSource) runInner() bool {
s.parent.onSourceStaticSetNotReady(pathSourceStaticSetNotReadyReq{source: s})
}()
rtcpSenders := rtcpsenderset.New(tracks, res.stream.onPacketRTCP)
rtcpSenders := rtcpsenderset.New(tracks, res.stream.writePacketRTCP)
defer rtcpSenders.Close()
onPacketRTP := func(trackID int, pkt *rtp.Packet) {
rtcpSenders.OnPacketRTP(trackID, pkt)
res.stream.onPacketRTP(trackID, pkt)
res.stream.writePacketRTP(trackID, pkt)
}
for {