(&self, fg: &Command)
| 26 | |
| 27 | impl DelayChannels { |
| 28 | pub(crate) fn send_delay(&self, fg: &Command) -> Result<(), EngineError> { |
| 29 | self.delay_tx.delay_tx.try_send(fg.clone())?; |
| 30 | Ok(()) |
| 31 | } |
| 32 | |
| 33 | pub(crate) fn send_move(&self, fg_move: Command) -> Result<(), EngineError> { |
| 34 | self.delay_move_tx.delay_tx.try_send(fg_move)?; |