Lines Matching refs:icpr
19 pub fn add(&mut self, icpr: Arc<dyn Interceptor + Send + Sync>) { in add()
20 self.interceptors.push(icpr); in add()
32 for icpr in &self.interceptors { in bind_rtcp_reader()
33 reader = icpr.bind_rtcp_reader(reader).await; in bind_rtcp_reader()
44 for icpr in &self.interceptors { in bind_rtcp_writer()
45 writer = icpr.bind_rtcp_writer(writer).await; in bind_rtcp_writer()
57 for icpr in &self.interceptors { in bind_local_stream()
58 writer = icpr.bind_local_stream(info, writer).await; in bind_local_stream()
65 for icpr in &self.interceptors { in unbind_local_stream()
66 icpr.unbind_local_stream(info).await; in unbind_local_stream()
77 for icpr in &self.interceptors { in bind_remote_stream()
78 reader = icpr.bind_remote_stream(info, reader).await; in bind_remote_stream()
85 for icpr in &self.interceptors { in unbind_remote_stream()
86 icpr.unbind_remote_stream(info).await; in unbind_remote_stream()
93 for icpr in &self.interceptors { in close()
94 if let Err(err) = icpr.close().await { in close()