(&self, task_id: &str)
| 118 | } |
| 119 | |
| 120 | pub async fn clear_canceller(&self, task_id: &str) { |
| 121 | self.cancellers.write().await.remove(task_id); |
| 122 | } |
| 123 | |
| 124 | /// Fire the registered token and mark the snapshot as `Cancelled`. |
| 125 | /// Returns `true` if a token was found (caller can interpret as |
no test coverage detected