Struct oxidiscovery::Discovery

pub struct Discovery {
    pub multicast_addr: SocketAddr,
    pub binding_addr: SocketAddr,
    pub transmission_delay: Duration,
    pub transmission_timeout: Duration,
    pub message: Vec<u8>,
}

Fields

multicast_addr: SocketAddr

binding_addr: SocketAddr

transmission_delay: Duration

transmission_timeout: Duration

message: Vec<u8>

Implementations

impl Discovery

pub fn discover<C: Fn(&mut Vec<Peer>) + Send + 'static>(
    &self,
    callback: C
) -> Result<DiscoveryManagment, Box<dyn Error>>

Example #1

  let peer_discovery: Discovery = Default::default();

  // peer_list was cloned and moved here
  let mut manager = peer_discovery
      .discover(move |peer_list| {
          println!("{:?}", peer_list);
      })?;

   // Will take 60 seconds for the timeout to hit.
   manager.wait();

Example #2

let lpeers: Arc<RwLock<Vec<Peer>>> = Arc::new(RwLock::new(Vec::new()));
let peers = lpeers.clone();

let peer_discovery: Discovery = Default::default();
// peer_list was cloned and moved here
let mut manager = peer_discovery
    .discover(move |peer_list| {
        let mut lock = peers.write().unwrap();
        lock.clear();
        lock.append(peer_list)
    })
    .or_else(|err| Err(EngineError::DiscoveryError(err)))?;

loop {
    let b = &mut manager;

    let lock = lpeers.read();
    let peers = lock.unwrap();
    if !peers.is_empty() || !b.is_alive() {
        println!("{:?}", peers);
        b.stop();
        break;
    }
    std::thread::sleep(std::time::Duration::from_millis(250))
}

Trait Implementations

impl Clone for Discovery

fn clone(&self) -> Discovery

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for Discovery

fn default() -> Self

Returns the "default value" for a type.