(&self, conn_id: u64)
| 69 | } |
| 70 | |
| 71 | pub fn take(&self, conn_id: u64) -> Option<RestorePending> { |
| 72 | let mut g = self.inner.lock().expect("RestoreState poisoned"); |
| 73 | g.remove(&conn_id) |
| 74 | } |
| 75 | |
| 76 | pub fn cancel(&self, conn_id: u64) { |
| 77 | let _ = self.take(conn_id); |