Struct ipc_channel::ipc::IpcReceiver
source · pub struct IpcReceiver<T> {
os_receiver: OsIpcReceiver,
phantom: PhantomData<T>,
}
Expand description
Receiving end of a channel using serialized messages.
Examples
Blocking IO
let response = rx.recv().unwrap();
println!("Received data...");
Non-blocking IO
loop {
match rx.try_recv() {
Ok(res) => {
// Do something interesting wth your result
println!("Received data...");
break;
},
Err(_) => {
// Do something else useful while we wait
println!("Still waiting...");
}
}
}
Embedding Receivers
let (tx, rx) = ipc::channel().unwrap();
let (embedded_tx, embedded_rx) = ipc::channel().unwrap();
// Send the IpcReceiver
tx.send(embedded_rx).unwrap();
// Receive the sent IpcReceiver
let received_rx = rx.recv().unwrap();
// Receive any data sent to the received IpcReceiver
let rx_data = received_rx.recv().unwrap();
Implementation details
Each IpcReceiver is backed by the OS specific implementations of OsIpcReceiver
.
Fields§
§os_receiver: OsIpcReceiver
§phantom: PhantomData<T>
Implementations§
source§impl<T> IpcReceiver<T>where
T: for<'de> Deserialize<'de> + Serialize,
impl<T> IpcReceiver<T>where
T: for<'de> Deserialize<'de> + Serialize,
Trait Implementations§
source§impl<T: Debug> Debug for IpcReceiver<T>
impl<T: Debug> Debug for IpcReceiver<T>
source§impl<'de, T> Deserialize<'de> for IpcReceiver<T>
impl<'de, T> Deserialize<'de> for IpcReceiver<T>
source§fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>where
D: Deserializer<'de>,
fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>where
D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more