[−][src]Struct ipc_channel::ipc::IpcReceiverSet
Collection of IpcReceivers moved into the set; thus creating a common (and exclusive) endpoint for receiving messages on any of the added channels.
Examples
let data = vec![0x52, 0x75, 0x73, 0x74, 0x00]; let (tx, rx) = ipc::channel().unwrap(); let mut rx_set = IpcReceiverSet::new().unwrap(); // Add the receiver to the receiver set and send the data // from the sender let rx_id = rx_set.add(rx).unwrap(); tx.send(data.clone()).unwrap(); // Poll the receiver set for any readable events for event in rx_set.select().unwrap() { match event { IpcSelectionResult::MessageReceived(id, message) => { let rx_data: Vec<u8> = message.to().unwrap(); assert_eq!(id, rx_id); assert_eq!(data, rx_data); println!("Received: {:?} from {}...", data, id); }, IpcSelectionResult::ChannelClosed(id) => { assert_eq!(id, rx_id); println!("No more data from {}...", id); } } }
Methods
impl IpcReceiverSet
[src]
pub fn new() -> Result<IpcReceiverSet, Error>
[src]
Create a new empty IpcReceiverSet.
Receivers may then be added to the set with the add method.
pub fn add<T>(&mut self, receiver: IpcReceiver<T>) -> Result<u64, Error> where
T: for<'de> Deserialize<'de> + Serialize,
[src]
T: for<'de> Deserialize<'de> + Serialize,
Add and consume the IpcReceiver to the set of receivers to be polled. IpcReceiver: struct.IpcReceiver.html
pub fn add_opaque(&mut self, receiver: OpaqueIpcReceiver) -> Result<u64, Error>
[src]
Add an OpaqueIpcReceiver to the set of receivers to be polled. OpaqueIpcReceiver: struct.OpaqueIpcReceiver.html
pub fn select(&mut self) -> Result<Vec<IpcSelectionResult>, Error>
[src]
Wait for IPC messages received on any of the receivers in the set. The method will return multiple events. An event may be either a message received or a channel closed event.
Auto Trait Implementations
impl RefUnwindSafe for IpcReceiverSet
impl Send for IpcReceiverSet
impl Sync for IpcReceiverSet
impl Unpin for IpcReceiverSet
impl UnwindSafe for IpcReceiverSet
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,