Lines Matching defs:map
138 let mut map = instance.lock().await;
139 map.insert(
147 let map = instance.lock().await;
149 for (_key, value) in map.iter() {
163 let map = instance.lock().await;
172 for (key, value) in map.iter() {
181 drop(map);
186 let mut map = instance.lock().await;
187 let result = map.remove(&remove_key);
207 let mut map = instance.write().await;
209 map.insert(id, arc_wr);
214 let map = arc_map.write().await;
215 let Some(arc_wr) = map.get(&id) else {
229 let mut map = instance.write().await;
230 if let Some(arc_wr) = map.remove(&id) {
252 let mut map = instance.write().await;
254 map.insert(id, arc_listener);
260 let mut map = instance.write().await;
261 if let Some(arc_listener) = map.remove(&id) {
284 let map = Self::get_instance();
285 let mut map = map.lock().await;
286 map.insert(cid, value.clone());
291 let map = Self::get_instance();
292 let mut map = map.lock().await;
293 let _ = map.remove(&cid);
298 let map = arc.lock().await;
299 let task = map.get(&cid);
323 let map = Self::get_instance();
324 let mut map = map.lock().await;
325 map.insert((session_id, channel_id), value.clone());
330 let map = Self::get_instance();
331 let mut map = map.lock().await;
332 let _ = map.remove(&(session_id, channel_id));
337 let map = arc.lock().await;
338 let task = map.get(&(session_id, channel_id));
354 let map = arc.lock().await;
355 for ((_session_id, _channel_id), value) in map.iter() {
367 let map = arc.lock().await;
368 if map.is_empty() {
371 for (&key, _) in map.iter() {
385 let map = arc.lock().await;
387 for (_id, forward_task) in map.iter() {