Struct Receiver

pub struct Receiver<T> { /* private fields */ }

A typed receiver.

Implementations

impl<T: Serialize + DeserializeOwned> Receiver<T>

pub fn connect<P: AsRef<Path>>(p: P) -> Result<Receiver<T>>

Connects a receiver to a named unix socket.

Examples found in repository

examples/simple.rs (line 16)

fn main() {
    let bootstrapper = Bootstrapper::new().unwrap();
    let path = bootstrapper.path().to_owned();

    std::thread::spawn(move || {
        let receiver = Receiver::<Task>::connect(path).unwrap();
        loop {
            let task = receiver.recv().unwrap();
            match task {
                Task::Sum(values, tx) => {
                    tx.send(values.into_iter().sum::<i64>()).unwrap();
                }
                Task::Shutdown => break,
            }
        }
    });

    println!("make channel 1");
    let (tx, rx) = channel().unwrap();
    bootstrapper.send(Task::Sum(vec![23, 42], tx)).unwrap();
    println!("result: {}", rx.recv().unwrap());

    println!("make channel 2");
    let (tx, rx) = channel().unwrap();
    bootstrapper.send(Task::Sum(vec![1, 2, 3], tx)).unwrap();
    println!("result: {}", rx.recv().unwrap());

    bootstrapper.send(Task::Shutdown).unwrap();
}

examples/proc.rs (line 17)

fn main() {
    if let Ok(path) = env::var(ENV_VAR) {
        let receiver = Receiver::<Task>::connect(path).unwrap();
        loop {
            let task = receiver.recv().unwrap();
            match dbg!(task) {
                Task::Sum(values, tx) => {
                    tx.send(values.into_iter().sum::<i64>()).unwrap();
                }
                Task::Shutdown => break,
            }
        }
    } else {
        let bootstrapper = Bootstrapper::new().unwrap();
        let mut child = process::Command::new(env::current_exe().unwrap())
            .env(ENV_VAR, bootstrapper.path())
            .spawn()
            .unwrap();

        let (tx, rx) = channel().unwrap();
        bootstrapper.send(Task::Sum(vec![23, 42], tx)).unwrap();
        println!("result: {}", rx.recv().unwrap());

        let (tx, rx) = channel().unwrap();
        bootstrapper.send(Task::Sum((0..10).collect(), tx)).unwrap();
        println!("result: {}", rx.recv().unwrap());

        bootstrapper.send(Task::Shutdown).unwrap();

        child.kill().ok();
        child.wait().ok();
    }
}

pub fn into_raw_receiver(self) -> RawReceiver

Converts the typed receiver into a raw one.

pub fn try_recv(&self) -> Result<Option<T>>

Receives a structured message from the socket if there is a message available.

pub fn recv(&self) -> Result<T>

Receives a structured message from the socket.

Examples found in repository

examples/simple.rs (line 18)

fn main() {
    let bootstrapper = Bootstrapper::new().unwrap();
    let path = bootstrapper.path().to_owned();

    std::thread::spawn(move || {
        let receiver = Receiver::<Task>::connect(path).unwrap();
        loop {
            let task = receiver.recv().unwrap();
            match task {
                Task::Sum(values, tx) => {
                    tx.send(values.into_iter().sum::<i64>()).unwrap();
                }
                Task::Shutdown => break,
            }
        }
    });

    println!("make channel 1");
    let (tx, rx) = channel().unwrap();
    bootstrapper.send(Task::Sum(vec![23, 42], tx)).unwrap();
    println!("result: {}", rx.recv().unwrap());

    println!("make channel 2");
    let (tx, rx) = channel().unwrap();
    bootstrapper.send(Task::Sum(vec![1, 2, 3], tx)).unwrap();
    println!("result: {}", rx.recv().unwrap());

    bootstrapper.send(Task::Shutdown).unwrap();
}

examples/proc.rs (line 19)

fn main() {
    if let Ok(path) = env::var(ENV_VAR) {
        let receiver = Receiver::<Task>::connect(path).unwrap();
        loop {
            let task = receiver.recv().unwrap();
            match dbg!(task) {
                Task::Sum(values, tx) => {
                    tx.send(values.into_iter().sum::<i64>()).unwrap();
                }
                Task::Shutdown => break,
            }
        }
    } else {
        let bootstrapper = Bootstrapper::new().unwrap();
        let mut child = process::Command::new(env::current_exe().unwrap())
            .env(ENV_VAR, bootstrapper.path())
            .spawn()
            .unwrap();

        let (tx, rx) = channel().unwrap();
        bootstrapper.send(Task::Sum(vec![23, 42], tx)).unwrap();
        println!("result: {}", rx.recv().unwrap());

        let (tx, rx) = channel().unwrap();
        bootstrapper.send(Task::Sum((0..10).collect(), tx)).unwrap();
        println!("result: {}", rx.recv().unwrap());

        bootstrapper.send(Task::Shutdown).unwrap();

        child.kill().ok();
        child.wait().ok();
    }
}

Trait Implementations

impl<T> AsRawFd for Receiver<T>

fn as_raw_fd(&self) -> RawFd

Extracts the raw file descriptor.

impl<T> Debug for Receiver<T>

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

Formats the value using the given formatter.

impl<'de, T: Serialize + DeserializeOwned> Deserialize<'de> for Receiver<T>

fn deserialize<D>(deserializer: D) -> Result<Receiver<T>, D::Error>

where D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<T: Serialize + DeserializeOwned> From<RawReceiver> for Receiver<T>

fn from(value: RawReceiver) -> Self

Converts to this type from the input type.

impl<T: Serialize + DeserializeOwned> FromRawFd for Receiver<T>

unsafe fn from_raw_fd(fd: RawFd) -> Self

Constructs a new instance of Self from the given raw file descriptor.

impl<T> IntoRawFd for Receiver<T>

fn into_raw_fd(self) -> RawFd

Consumes this object, returning the raw underlying file descriptor.

impl<T: Serialize + DeserializeOwned> Serialize for Receiver<T>

fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>

where S: Serializer,

Serialize this value into the given Serde serializer.