Struct GenericReceiverSet 

pub struct GenericReceiverSet<T: Serialize + for<'de> Deserialize<'de>>(GenericReceiverSetVariants<T>);

A GenericReceiverSet. Allows you to wait on multiple GenericReceivers. Automatically selects either Ipc or crossbeam depending on multiprocess mode.

Examples

let mut rx_set = GenericReceiverSet::new();
let private_channel = generic_channel::channel().unwrap();
let public_channel = generic_channel::channel().unwrap();
let reporter_channel = generic_channel::channel().unwrap();
let private_id = rx_set.add(private_receiver);
let public_id = rx_set.add(public_receiver);
let reporter_id = rx_set.add(memory_reporter);
for received in rx_set.select().into_iter() {
    match received {
        GenericSelectionResult::ChannelClosed(_) => continue,
        GenericSelectionResult::Error => println!("Found selection error"),
        GenericSelectionResult::MessageReceived(id, msg) => { /*...*/ }
    }
}

Tuple Fields

0: GenericReceiverSetVariants<T>

Implementations

impl<T: Serialize + for<'de> Deserialize<'de>> GenericReceiverSet<T>

pub fn new() -> GenericReceiverSet<T>

Create a new ReceiverSet.

pub fn add(&mut self, receiver: GenericReceiver<T>) -> u64

Add a receiver to the set.

pub fn selector(&mut self) -> Selector<'_, T>

Create a Selector that owns the underlying select state.

Examples

 use servo_base::generic_channel::{self, GenericReceiverSet};

 let (_, receiver_one) = generic_channel::channel::<()>().unwrap();
 let (_, receiver_two) = generic_channel::channel::<()>().unwrap();
 let mut rx_set = GenericReceiverSet::<()>::new();
 let _select_idx_1 = rx_set.add(receiver_one);
 let _select_idx_2 = rx_set.add(receiver_two);
 // Build the Selector once, before the loop if all receivers are known in advance.
 let mut selector = rx_set.selector();
 loop {
   for received in selector.select().into_iter() {
     // do something
   }
 }

pub fn select(&mut self) -> Vec<GenericSelectionResult<T>>

One-shot select. Builds a Selector, runs select once and drops it.

For usage in loops consider using GenericReceiverSet::selector() to build the selector once upfront.

Trait Implementations

impl<T: Serialize + for<'de> Deserialize<'de>> Default for GenericReceiverSet<T>

fn default() -> Self

Returns the “default value” for a type.