Struct NamedPipeWriter

pub struct NamedPipeWriter { /* private fields */ }

A convenience wrapper for writing to Unix named pipes.

Implementations

impl NamedPipeWriter

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

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/write_repeat.rs (line 23)

fn main() -> io::Result<()> {
    let text = std::env::args()
        .nth(1)
        .unwrap_or_else(|| "Hello world!".to_string())
        + "\n";
    println!("Writing String: {}", &text);
    task::block_on(async move {
        let pipe = NamedPipePath::new("./my_pipe");
        let writer = pipe.open_write();
        loop {
            writer.ensure_pipe_exists().unwrap();
            println!("Waiting for receiver...");
            writer.write_str(&text).await?;
        }
    })
}

pub async fn write(&self, data: &[u8]) -> Result<()>

Writes byte data to the pipe. The returned Future will resolve when the bytes are read from the pipe.

pub async fn write_str(&self, data: &str) -> Result<()>

Writes &str data to the pipe. The returned Future will resolve when the string is read from the pipe.

Examples found in repository

examples/write_repeat.rs (line 25)

fn main() -> io::Result<()> {
    let text = std::env::args()
        .nth(1)
        .unwrap_or_else(|| "Hello world!".to_string())
        + "\n";
    println!("Writing String: {}", &text);
    task::block_on(async move {
        let pipe = NamedPipePath::new("./my_pipe");
        let writer = pipe.open_write();
        loop {
            writer.ensure_pipe_exists().unwrap();
            println!("Waiting for receiver...");
            writer.write_str(&text).await?;
        }
    })
}

examples/read_write_repeat.rs (line 25)

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?;
        }
    })
}