Method recv_cmd

src/executor/shared/fifo.rs:134–144

(&mut self)

    }

    pub async fn recv_cmd(&mut self) -> anyhow::Result<FifoCommand> {
        let bytes = self
            .ctl_reader
            .next()
            .await
            .ok_or_else(|| anyhow::anyhow!("FIFO stream closed"))??;

        let decoded = bincode::deserialize(&bytes)
            .with_context(|| format!("Failed to deserialize FIFO command (data: {bytes:?})"))?;
        Ok(decoded)
    }

    pub async fn send_cmd(&mut self, cmd: FifoCommand) -> anyhow::Result<()> {
        let encoded = bincode::serialize(&cmd)?;