make send rtp keepalive public
This commit is contained in:
parent
c490b69c0e
commit
0837c385a6
@ -118,7 +118,7 @@ func (self *Client) Streams() (streams []av.CodecData, err error) {
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
func (self *Client) sendRtpKeepalive() (err error) {
|
func (self *Client) SendRtpKeepalive() (err error) {
|
||||||
if self.RtpKeepAliveTimeout > 0 && self.rtpKeepaliveEnterCnt == 0 {
|
if self.RtpKeepAliveTimeout > 0 && self.rtpKeepaliveEnterCnt == 0 {
|
||||||
self.rtpKeepaliveEnterCnt++
|
self.rtpKeepaliveEnterCnt++
|
||||||
defer func() {
|
defer func() {
|
||||||
@ -201,7 +201,7 @@ func (self *Client) ReadResponse() (res Response, err error) {
|
|||||||
if _, err = io.ReadFull(self.rconn, res.Block); err != nil {
|
if _, err = io.ReadFull(self.rconn, res.Block); err != nil {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
if err = self.sendRtpKeepalive(); err != nil {
|
if err = self.SendRtpKeepalive(); err != nil {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user