(
mut self: core::pin::Pin<&mut Self>,
cx: &mut core::task::Context<'_>,
)
| 186 | impl futures::future::Future for YieldOnce { |
| 187 | type Output = (); |
| 188 | fn poll( |
| 189 | mut self: core::pin::Pin<&mut Self>, |
| 190 | cx: &mut core::task::Context<'_>, |
| 191 | ) -> core::task::Poll<Self::Output> { |
| 192 | if !self.0 { |
| 193 | self.as_mut().0 = true; |
| 194 | let aw = AtomicWaker::new(); |
| 195 | aw.register(&cx.waker()); |
| 196 | YIELDERS.push(aw); |
| 197 | core::task::Poll::Pending |
| 198 | } else { |
| 199 | core::task::Poll::Ready(()) |
| 200 | } |
| 201 | } |
| 202 | } |
no outgoing calls
no test coverage detected