pub fn new(fifo_path: PathBuf) -> Result<Writer> {
        OpenOptions::new()
            .custom_flags(O_NONBLOCK)
            .read(true)
            .write(true)
            .open(&fifo_path)
            .map(|t| Writer {
                line_writer: Mutex::new(io::LineWriter::new(t)),
            })
    }
/// Create and open a FIFO for writing to it.
/// In order to not block the instance if nobody is consuming the message that is flushed to the
/// two pipes, we are opening it with `O_NONBLOCK` flag. In this case, writing to a pipe will
/// start failing when reaching 64K of unconsumed content. Simultaneously,
/// the `missed_metrics_count` metric will get increased.
Create and open a FIFO for writing to it.
In order to not block the instance if nobody is consuming the message that is flushed to the
two pipes, we are opening it with `O_NONBLOCK` flag. In this case, writing to a pipe will
start failing when reaching 64K of unconsumed content. Simultaneously,
the `missed_metrics_count` metric will get increased.
Create and open a FIFO for writing to it . In order to not block the instance if nobody is consuming the message that is flushed to the two pipes we are opening it with ` O_NONBLOCK ` flag . In this case writing to a pipe will start failing when reaching 64K of unconsumed content . Simultaneously the ` missed_metrics_count ` metric will get increased .
pub fn new(fifo_path: PathBuf) -> Result<Writer> {
        OpenOptions::new()
            .custom_flags(O_NONBLOCK)
            .read(true)
            .write(true)
            .open(&fifo_path)
            .map(|t| Writer {
                line_writer: Mutex::new(io::LineWriter::new(t)),
            })
    }
pub fn new ( fifo_path : PathBuf ) -> Result < Writer > { OpenOptions :: new ( ) . custom_flags ( O_NONBLOCK ) . read ( true ) . write ( true ) . open ( & fifo_path ) . map ( | t | Writer { line_writer : Mutex :: new ( io :: LineWriter :: new ( t ) ) , } ) }
Create and open a FIFO for writing to it.
Create and open a FIFO for writing to it .
fifo_path
PathBuf