webrtc: export GetSenderTrack
This commit is contained in:
+10
-10
@@ -161,16 +161,7 @@ func (c *Conn) AddCandidate(candidate string) error {
|
|||||||
return c.pc.AddICECandidate(webrtc.ICECandidateInit{Candidate: candidate})
|
return c.pc.AddICECandidate(webrtc.ICECandidateInit{Candidate: candidate})
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c *Conn) getTranseiver(mid string) *webrtc.RTPTransceiver {
|
func (c *Conn) GetSenderTrack(mid string) *Track {
|
||||||
for _, tr := range c.pc.GetTransceivers() {
|
|
||||||
if tr.Mid() == mid {
|
|
||||||
return tr
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func (c *Conn) getSenderTrack(mid string) *Track {
|
|
||||||
if tr := c.getTranseiver(mid); tr != nil {
|
if tr := c.getTranseiver(mid); tr != nil {
|
||||||
if s := tr.Sender(); s != nil {
|
if s := tr.Sender(); s != nil {
|
||||||
if t := s.Track().(*Track); t != nil {
|
if t := s.Track().(*Track); t != nil {
|
||||||
@@ -181,6 +172,15 @@ func (c *Conn) getSenderTrack(mid string) *Track {
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (c *Conn) getTranseiver(mid string) *webrtc.RTPTransceiver {
|
||||||
|
for _, tr := range c.pc.GetTransceivers() {
|
||||||
|
if tr.Mid() == mid {
|
||||||
|
return tr
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
func (c *Conn) getMediaCodec(remote *webrtc.TrackRemote) (*core.Media, *core.Codec) {
|
func (c *Conn) getMediaCodec(remote *webrtc.TrackRemote) (*core.Media, *core.Codec) {
|
||||||
for _, tr := range c.pc.GetTransceivers() {
|
for _, tr := range c.pc.GetTransceivers() {
|
||||||
// search Transeiver for this TrackRemote
|
// search Transeiver for this TrackRemote
|
||||||
|
|||||||
Reference in New Issue
Block a user