From 2828381dc4cc89c2e1c62a4ae8f210cf39630fb6 Mon Sep 17 00:00:00 2001 From: aggresss Date: Sat, 10 Feb 2024 21:37:47 +0800 Subject: [PATCH] Fix interceptor.RTCPReaderFunc typo --- dtlstransport.go | 2 +- rtpsender.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) 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 }),