Struct linux_ipc::IpcChannel

pub struct IpcChannel { /* private fields */ }

Implementations

impl IpcChannel

pub fn new(path: &str) -> Result<Self>

Examples found in repository

examples/server.rs (line 13)

fn main() {
    println!("Creating example channel");
    let mut channel = IpcChannel::new("/tmp/example.sock").expect("Failed to create channel");

    loop {
        println!("Receiving post in channel `init`");
        let result = channel.receive::<Post>();

        if result.is_err() {
            eprintln!("{}", result.unwrap_err());
        } else {
            let result = result.unwrap();
            println!("{:?}", result);
        }
    }
}

pub fn connect(path: &str) -> Result<Self>

Examples found in repository

examples/client.rs (line 22)

fn main() {
    println!("Connecting to example channel");
    let mut channel = IpcChannel::connect("/tmp/example.sock").expect("Failed to create channel");
    let post = Post::new(
        "Hello world!",
        "Lorem ipsum dolor sit amet, consectetur adipiscing elit, sed do eiusmod tempor incididunt ut labore et dolore magna aliqua. Diam phasellus vestibulum lorem sed risus ultricies tristique nulla. Nibh sit amet commodo nulla facilisi nullam vehicula ipsum a. Eget dolor morbi non arcu risus quis varius. Et ligula ullamcorper malesuada proin libero nunc consequat interdum varius."
    );

    println!("Sending message in channel `example`");
    let response = channel.send(post).expect("Failed to send message");

    if response.is_some() {
        print!("{}", response.unwrap());
    }
}

pub fn send<T: Serialize>(&mut self, value: T) -> Result<Option<String>>

Examples found in repository

examples/client.rs (line 29)

fn main() {
    println!("Connecting to example channel");
    let mut channel = IpcChannel::connect("/tmp/example.sock").expect("Failed to create channel");
    let post = Post::new(
        "Hello world!",
        "Lorem ipsum dolor sit amet, consectetur adipiscing elit, sed do eiusmod tempor incididunt ut labore et dolore magna aliqua. Diam phasellus vestibulum lorem sed risus ultricies tristique nulla. Nibh sit amet commodo nulla facilisi nullam vehicula ipsum a. Eget dolor morbi non arcu risus quis varius. Et ligula ullamcorper malesuada proin libero nunc consequat interdum varius."
    );

    println!("Sending message in channel `example`");
    let response = channel.send(post).expect("Failed to send message");

    if response.is_some() {
        print!("{}", response.unwrap());
    }
}

pub fn receive<T: DeserializeOwned + Debug>(&mut self) -> Result<T>

Examples found in repository

examples/server.rs (line 17)

fn main() {
    println!("Creating example channel");
    let mut channel = IpcChannel::new("/tmp/example.sock").expect("Failed to create channel");

    loop {
        println!("Receiving post in channel `init`");
        let result = channel.receive::<Post>();

        if result.is_err() {
            eprintln!("{}", result.unwrap_err());
        } else {
            let result = result.unwrap();
            println!("{:?}", result);
        }
    }
}

Trait Implementations

impl Debug for IpcChannel

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Drop for IpcChannel

fn drop(&mut self)

Executes the destructor for this type.