Fix interceptor.RTCPReaderFunc typo

aggresss · Sean-Der · commit dbf22543feed · 2024-02-10T21:16:12.000-05:00
diff --git a/dtlstransport.go b/dtlstransport.go
@@ -508,7 +508,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
@@ -325,7 +325,7 @@ func (r *RTPSender) Send(parameters RTPSendParameters) error {
 		)
 
 		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
`@@ -508,7 +508,7 @@ func (t *DTLSTransport) streamsForSSRC(ssrc SSRC, streamInfo interceptor.StreamI`
`508`	`508`	`return nil, nil, nil, nil, err`
`509`	`509`	`}`
`510`	`510`
`511`		`- rtcpInterceptor := t.api.interceptor.BindRTCPReader(interceptor.RTPReaderFunc(func(in []byte, a interceptor.Attributes) (n int, attributes interceptor.Attributes, err error) {`
	`511`	`+ rtcpInterceptor := t.api.interceptor.BindRTCPReader(interceptor.RTCPReaderFunc(func(in []byte, a interceptor.Attributes) (n int, attributes interceptor.Attributes, err error) {`
`512`	`512`	`n, err = rtcpReadStream.Read(in)`
`513`	`513`	`return n, a, err`
`514`	`514`	`}))`
Original file line number	Diff line number	Diff line change
`@@ -325,7 +325,7 @@ func (r *RTPSender) Send(parameters RTPSendParameters) error {`
`325`	`325`	`)`
`326`	`326`
`327`	`327`	`trackEncoding.rtcpInterceptor = r.api.interceptor.BindRTCPReader(`
`328`		`- interceptor.RTPReaderFunc(func(in []byte, a interceptor.Attributes) (n int, attributes interceptor.Attributes, err error) {`
	`328`	`+ interceptor.RTCPReaderFunc(func(in []byte, a interceptor.Attributes) (n int, attributes interceptor.Attributes, err error) {`
`329`	`329`	`n, err = trackEncoding.srtpStream.Read(in)`
`330`	`330`	`return n, a, err`
`331`	`331`	`}),`