Method write_message

components/vmworker/src/lib.rs:353–359

(&mut self, v: WorkerMessage)

    }

    async fn write_message(&mut self, v: WorkerMessage) -> anyhow::Result<()> {
        if self.scheduler_tx.send(v).is_err() {
            Err(anyhow::anyhow!("scheduler tx closed"))
        } else {
            Ok(())
        }
    }

    async fn wait_shutdown_current_vm(&mut self) -> anyhow::Result<()> {
        let Some(current) = self.current_state.take() else {