Fix interceptor.RTCPReaderFunc typo

aggresss · Sean-Der · commit 2828381dc4cc · 2024-02-10T22:34:39.000-05:00
diff --git a/dtlstransport.go b/dtlstransport.go
@@ -505,7 +505,7 @@ func (t *DTLSTransport) streamsForSSRC(ssrc SSRC, streamInfo interceptor.StreamI
 		return nil, nil, nil, nil, err
 	}
 
-	rtcpInterceptor := t.api.interceptor.BindRTCPReader(interceptor.RTPReaderFunc(func(in []byte, a interceptor.Attributes) (n int, attributes interceptor.Attributes, err error) {
+	rtcpInterceptor := t.api.interceptor.BindRTCPReader(interceptor.RTCPReaderFunc(func(in []byte, a interceptor.Attributes) (n int, attributes interceptor.Attributes, err error) {
 		n, err = rtcpReadStream.Read(in)
 		return n, a, err
 	}))
diff --git a/rtpsender.go b/rtpsender.go
@@ -204,7 +204,7 @@ func (r *RTPSender) addEncoding(track TrackLocal) {
 	}
 	trackEncoding.srtpStream.rtpSender = r
 	trackEncoding.rtcpInterceptor = r.api.interceptor.BindRTCPReader(
-		interceptor.RTPReaderFunc(func(in []byte, a interceptor.Attributes) (n int, attributes interceptor.Attributes, err error) {
+		interceptor.RTCPReaderFunc(func(in []byte, a interceptor.Attributes) (n int, attributes interceptor.Attributes, err error) {
 			n, err = trackEncoding.srtpStream.Read(in)
 			return n, a, err
 		}),

Original file line number	Diff line number	Diff line change
`@@ -505,7 +505,7 @@ func (t *DTLSTransport) streamsForSSRC(ssrc SSRC, streamInfo interceptor.StreamI`
`505`	`505`	`return nil, nil, nil, nil, err`
`506`	`506`	`}`
`507`	`507`
`508`		`- rtcpInterceptor := t.api.interceptor.BindRTCPReader(interceptor.RTPReaderFunc(func(in []byte, a interceptor.Attributes) (n int, attributes interceptor.Attributes, err error) {`
	`508`	`+ rtcpInterceptor := t.api.interceptor.BindRTCPReader(interceptor.RTCPReaderFunc(func(in []byte, a interceptor.Attributes) (n int, attributes interceptor.Attributes, err error) {`
`509`	`509`	`n, err = rtcpReadStream.Read(in)`
`510`	`510`	`return n, a, err`
`511`	`511`	`}))`
Original file line number	Diff line number	Diff line change
`@@ -204,7 +204,7 @@ func (r *RTPSender) addEncoding(track TrackLocal) {`
`204`	`204`	`}`
`205`	`205`	`trackEncoding.srtpStream.rtpSender = r`
`206`	`206`	`trackEncoding.rtcpInterceptor = r.api.interceptor.BindRTCPReader(`
`207`		`- interceptor.RTPReaderFunc(func(in []byte, a interceptor.Attributes) (n int, attributes interceptor.Attributes, err error) {`
	`207`	`+ interceptor.RTCPReaderFunc(func(in []byte, a interceptor.Attributes) (n int, attributes interceptor.Attributes, err error) {`
`208`	`208`	`n, err = trackEncoding.srtpStream.Read(in)`
`209`	`209`	`return n, a, err`
`210`	`210`	`}),`