(&mut self, future: HostTaskFuture)
| 5221 | } |
| 5222 | |
| 5223 | fn push_future(&mut self, future: HostTaskFuture) { |
| 5224 | // Note that we can't directly push to `ConcurrentState::futures` here |
| 5225 | // since this may be called from a future that's being polled inside |
| 5226 | // `Self::poll_until`, which temporarily removes the `FuturesUnordered` |
| 5227 | // so it has exclusive access while polling it. Therefore, we push a |
| 5228 | // work item to the "high priority" queue, which will actually push to |
| 5229 | // `ConcurrentState::futures` later. |
| 5230 | self.push_high_priority(WorkItem::PushFuture(AlwaysMut::new(future))); |
| 5231 | } |
| 5232 | |
| 5233 | fn push_high_priority(&mut self, item: WorkItem) { |
| 5234 | log::trace!("push high priority: {item:?}"); |
no test coverage detected