(&self)
| 3090 | } |
| 3091 | |
| 3092 | pub async fn exit(&self) { |
| 3093 | // As in `Self::marked_closed`, `Relaxed` is sufficient because we're not synchronizing any external state. |
| 3094 | self.closed.store(true, std::sync::atomic::Ordering::Relaxed); |
| 3095 | self.scheduler().close(); |
| 3096 | self.exited().await; |
| 3097 | } |
| 3098 | |
| 3099 | pub async fn exited(&self) { |
| 3100 | self.scheduler().closed().await; |
no test coverage detected