(&self, key: &K)
| 152 | } |
| 153 | |
| 154 | pub fn get(&self, key: &K) -> Option<Arc<Doc>> { |
| 155 | |
| 156 | let state = self.shared.state.lock().unwrap(); |
| 157 | state.entries.get(key).map(|entry| entry.data.clone()) |
| 158 | } |
| 159 | |
| 160 | pub fn set(&self, key: K, value: Doc, expire: Option<Duration>) { |
| 161 | let mut state: std::sync::MutexGuard<'_, State<K, Doc>> = self.shared.state.lock().unwrap(); |
nothing calls this directly
no outgoing calls
no test coverage detected