(&self)
| 166 | } |
| 167 | |
| 168 | pub(super) fn run_id(&self) -> &str { |
| 169 | &self.run_id |
| 170 | } |
| 171 | |
| 172 | pub(super) async fn set_cancel_token(&self, token: tokio_util::sync::CancellationToken) { |
| 173 | *self.cancel_token.lock().await = Some(token); |
no outgoing calls
no test coverage detected