(&self)
| 182 | } |
| 183 | |
| 184 | pub(super) async fn clear_cancel_token(&self) { |
| 185 | *self.cancel_token.lock().await = None; |
| 186 | } |
| 187 | |
| 188 | /// Returns `true` when the per-run cancellation token (or any parent it |
| 189 | /// was derived from, such as the session-level token) has been fired. |