diff --git a/dtlstransport.go b/dtlstransport.go
index d468eca70b5..0267ca591dc 100644
--- 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
index 5b1b5d58554..0c0e867ecdc 100644
--- 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
 		}),