mirror of
https://github.com/aler9/gortsplib
synced 2025-10-30 18:16:29 +08:00
unexport connClientUDPListener.read
This commit is contained in:
@@ -33,8 +33,7 @@ func (l *connClientUDPListener) close() {
|
|||||||
l.pc.Close()
|
l.pc.Close()
|
||||||
}
|
}
|
||||||
|
|
||||||
// Read reads a frame from the publisher.
|
func (l *connClientUDPListener) read(buf []byte) (int, error) {
|
||||||
func (l *connClientUDPListener) Read(buf []byte) (int, error) {
|
|
||||||
for {
|
for {
|
||||||
n, addr, err := l.pc.ReadFrom(buf)
|
n, addr, err := l.pc.ReadFrom(buf)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
|||||||
@@ -446,7 +446,7 @@ func (c *ConnClient) SetupUDP(u *url.URL, track *Track, rtpPort int,
|
|||||||
rtcpListener.publisherPort = (*th.ServerPorts)[1]
|
rtcpListener.publisherPort = (*th.ServerPorts)[1]
|
||||||
c.rtcpListeners[track.Id] = rtcpListener
|
c.rtcpListeners[track.Id] = rtcpListener
|
||||||
|
|
||||||
return rtpListener.Read, rtcpListener.Read, res, nil
|
return rtpListener.read, rtcpListener.read, res, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// SetupTCP writes a SETUP request, that means that we want to read
|
// SetupTCP writes a SETUP request, that means that we want to read
|
||||||
|
|||||||
Reference in New Issue
Block a user