Asks the vm to finish its pending work and shut down gracefully, the worker will send a [WorkerMessage::Shutdown] for the current session when done.
(&mut self)
| 198 | /// worker will send a [WorkerMessage::Shutdown] for the current session |
| 199 | /// when done. |
| 200 | pub fn send_complete(&mut self) -> Result<(), ()> { |
| 201 | self.worker.tx.send(SchedulerMessage::Complete).map_err(|_| ()) |
| 202 | } |
| 203 | |
| 204 | pub async fn recv(&mut self) -> Option<WorkerMessage> { |
| 205 | self.worker.rx.recv().await |