(&self, token: tokio_util::sync::CancellationToken)
| 158 | } |
| 159 | |
| 160 | pub(super) async fn set_cancel_token(&self, token: tokio_util::sync::CancellationToken) { |
| 161 | self.cleanup.set_cancel_token(token).await; |
| 162 | } |
| 163 | |
| 164 | pub(super) async fn complete<E>( |
| 165 | self, |