Searched refs:is_closed (Results 1 – 10 of 10) sorted by relevance
102 pub async fn is_closed(&self) -> bool { in is_closed() method224 if self.is_closed().await { in close()258 if self.is_closed().await { in get_conn()309 if self.is_closed().await { in register_conn_for_address()
99 pub fn is_closed(&self) -> bool { in is_closed() method100 self.inner.is_closed() in is_closed()206 fn is_closed(&self) -> bool { in is_closed() method
157 is_closed: Arc<AtomicBool>, field173 is_closed: Arc<AtomicBool>, field384 if params.is_closed.load(Ordering::SeqCst) { in negotiation_needed_op()862 is_closed: &Arc<AtomicBool>, in update_connection_state()869 if is_closed.load(Ordering::SeqCst) { in update_connection_state()967 if self.internal.is_closed.load(Ordering::SeqCst) { in set_description()1193 if self.internal.is_closed.load(Ordering::SeqCst) { in set_local_description()1301 if self.internal.is_closed.load(Ordering::SeqCst) { in set_remote_description()1673 if self.internal.is_closed.load(Ordering::SeqCst) { in add_track()1713 if self.internal.is_closed.load(Ordering::SeqCst) { in remove_track()[all …]
29 pub(super) is_closed: Arc<AtomicBool>, field85 is_closed: Arc::new(AtomicBool::new(false)), in new()237 let is_closed = Arc::clone(&self.is_closed); in undeclared_media_processor() localVariable260 if is_closed.load(Ordering::SeqCst) { in undeclared_media_processor()435 if self.is_closed.load(Ordering::SeqCst) { in add_transceiver_from_kind()553 is_closed: Arc::clone(&self.is_closed), in create_negotiation_needed_params()634 &self.is_closed, in start_transports()1109 let is_closed = Arc::clone(&self.is_closed); in create_ice_transport() localVariable1136 let is_closed2 = Arc::clone(&is_closed); in create_ice_transport()
39 async fn is_closed(&self) -> bool { in is_closed() method105 if self.is_closed().await { in bind_rtcp_writer()
77 async fn is_closed(&self) -> bool { in is_closed() method147 if self.is_closed().await { in bind_rtcp_writer()
108 async fn is_closed(&self) -> bool { in is_closed() method181 if self.is_closed().await { in bind_rtcp_writer()
89 async fn is_closed(&self) -> bool { in is_closed() method166 if self.is_closed().await { in bind_rtcp_writer()
280 pub async fn is_closed(&self) -> bool { in is_closed() method
354 assert!(buffer.is_closed().await); in test_buffer_misc()