Method new

src/executor/shared/fifo.rs:36–49

(ctl_fifo: &Path, ack_fifo: &Path)

impl GenericFifo {
    pub fn new(ctl_fifo: &Path, ack_fifo: &Path) -> anyhow::Result<Self> {
        create_fifo(ctl_fifo)?;
        create_fifo(ack_fifo)?;

        let ctl_sender = open_fifo_sender(ctl_fifo)?;
        let ack_reader = open_fifo_receiver(ack_fifo)?;

        Ok(Self {
            ctl_path: ctl_fifo.to_path_buf(),
            ack_path: ack_fifo.to_path_buf(),
            ctl_sender,
            ack_reader,
        })
    }

    pub fn ctl_sender(&mut self) -> &mut TokioPipeSender {
        &mut self.ctl_sender