(&mut self, cmd: FifoCommand)
| 144 | } |
| 145 | |
| 146 | pub async fn send_cmd(&mut self, cmd: FifoCommand) -> anyhow::Result<()> { |
| 147 | let encoded = bincode::serialize(&cmd)?; |
| 148 | |
| 149 | self.ack_fifo |
| 150 | .write_all(&(encoded.len() as u32).to_le_bytes()) |
| 151 | .await?; |
| 152 | self.ack_fifo.write_all(&encoded).await?; |
| 153 | Ok(()) |
| 154 | } |
| 155 | |
| 156 | /// Handles all incoming FIFO messages until it's closed, or until the child process exits. |
| 157 | /// |
no outgoing calls
no test coverage detected