Struct NamedPipeReader

pub struct NamedPipeReader { /* private fields */ }

A convenience wrapper for reading from Unix named pipes.

Implementations

impl NamedPipeReader

pub fn from_path(source: &NamedPipePath) -> Self

Creates a new reader, cloning the given NamedPipePath.

pub fn ensure_pipe_exists(&self) -> Result<&Self>

Checks if the named pipe actually exists and tries to create it if it doesn’t.

Examples found in repository

examples/read_print_repeat.rs (line 18)

fn main() -> io::Result<()> {
    task::block_on(async {
        let pipe = NamedPipePath::new("./my_pipe");
        let reader = pipe.open_read();
        loop {
            reader.ensure_pipe_exists().unwrap();
            println!("Waiting for message...");
            let next_msg = reader.read_string().await?;
            println!("Received message: {}", next_msg);
        }
    })
}

pub async fn read(&self) -> Result<Vec<u8>>

Reads all bytes from the pipe. The returned Future will resolve when something is written to the pipe.

pub async fn read_string(&self) -> Result<String>

Reads a String from the pipe. The returned Future will resolve when something is written to the pipe.

Examples found in repository

examples/read_print_repeat.rs (line 20)

fn main() -> io::Result<()> {
    task::block_on(async {
        let pipe = NamedPipePath::new("./my_pipe");
        let reader = pipe.open_read();
        loop {
            reader.ensure_pipe_exists().unwrap();
            println!("Waiting for message...");
            let next_msg = reader.read_string().await?;
            println!("Received message: {}", next_msg);
        }
    })
}

examples/read_write_repeat.rs (line 20)

fn main() -> io::Result<()> {
    task::block_on(async move {
        let pipe = NamedPipePath::new("./reverse_me");
        let writer = pipe.open_write();
        let reader = pipe.open_read();
        loop {
            pipe.ensure_exists().unwrap();
            println!("Waiting for message...");
            let msg = reader.read_string().await?;

            let answer = msg.chars().rev().collect::<String>() + "\n";
            pipe.ensure_exists().unwrap();
            println!("Received message, waiting for receiver...");
            writer.write_str(&answer).await?;
        }
    })
}