Pull every resolved async result into `out`.
(&mut self, out: &mut VecDeque<Message>)
| 98 | |
| 99 | /// Pull every resolved async result into `out`. |
| 100 | pub fn drain_results(&mut self, out: &mut VecDeque<Message>) { |
| 101 | while let Ok(Some(message)) = self.results_receiver.try_next() { |
| 102 | out.push_back(message); |
| 103 | } |
| 104 | } |
| 105 | } |
| 106 | |
| 107 | impl Default for FutureMessageHandler { |