Struct IpcChannel

pub struct IpcChannel { /* private fields */ }

Implementations

impl IpcChannel

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

Examples found in repository

examples/server.rs (line 11)

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

    loop {
        let (response, reply) = channel.receive::<Test, Test>().expect("Failed to receive post");
        println!("Received: {:#?}", response);

        let to_send = Test {
            name: response.content,
            content: response.name,
        };

        println!("Sending: {:#?}", to_send);

        reply(to_send).expect("Failed to reply to client");
    }
}

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

Examples found in repository

examples/client.rs (line 13)

fn main() {
    let arg = &env::args().collect::<Vec<String>>()[1..].join(" ");
    let mut channel = IpcChannel::connect("/tmp/example.sock").expect("Failed to create channel");

    for _ in 0..2 {
        let test = Test {
            name: "test".to_string(),
            content: arg.to_string(),
        };

        println!("Sending: {:#?}", test);

        let response = channel.send::<_, Test>(test).expect("Failed to send message");

        if let Some(response) = response {
            println!("Received: {:#?}", response);
        }
    }
}

pub fn send<T: Serialize, R: DeserializeOwned + Debug>( &mut self, value: T, ) -> Result<Option<R>>

Examples found in repository

examples/client.rs (line 23)

fn main() {
    let arg = &env::args().collect::<Vec<String>>()[1..].join(" ");
    let mut channel = IpcChannel::connect("/tmp/example.sock").expect("Failed to create channel");

    for _ in 0..2 {
        let test = Test {
            name: "test".to_string(),
            content: arg.to_string(),
        };

        println!("Sending: {:#?}", test);

        let response = channel.send::<_, Test>(test).expect("Failed to send message");

        if let Some(response) = response {
            println!("Received: {:#?}", response);
        }
    }
}

pub fn receive<T: DeserializeOwned + Debug, R: Serialize>( &mut self, ) -> Result<(T, Box<dyn FnOnce(R) -> Result<()>>)>

Examples found in repository

examples/server.rs (line 14)

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

    loop {
        let (response, reply) = channel.receive::<Test, Test>().expect("Failed to receive post");
        println!("Received: {:#?}", response);

        let to_send = Test {
            name: response.content,
            content: response.name,
        };

        println!("Sending: {:#?}", to_send);

        reply(to_send).expect("Failed to reply to client");
    }
}

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.