Searched refs:endpoints (Results 1 – 4 of 4) sorted by relevance
34 endpoints: Arc<Mutex<HashMap<usize, Arc<Endpoint>>>>, field45 endpoints: Arc::new(Mutex::new(HashMap::new())), in new()52 let endpoints = Arc::clone(&m.endpoints); in new() localVariable62 let mut endpoints = self.endpoints.lock().await; in new_endpoint() localVariable73 endpoints: Arc::clone(&self.endpoints), in new_endpoint()76 endpoints.insert(e.id, Arc::clone(&e)); in new_endpoint()83 let mut endpoints = self.endpoints.lock().await; in remove_endpoint() localVariable84 endpoints.remove(&e.id); in remove_endpoint()91 let mut endpoints = self.endpoints.lock().await; in close() localVariable92 endpoints.clear(); in close()[all …]
17 pub(crate) endpoints: Arc<Mutex<HashMap<usize, Arc<Endpoint>>>>, field25 let mut endpoints = self.endpoints.lock().await; in close() localVariable26 endpoints.remove(&self.id); in close()
37 Mux::dispatch(&[0], &m.endpoints).await?; in test_no_endpoints()
29 The demo code implements two endpoints (requester and responder) in it.