diffusion 0.6.2

This is the rust implementation of diffusion library. Diffusion is an effcient message-based data distribution library. 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

#![feature(convert)]
extern crate diffusion;
use diffusion::Reader;
use diffusion::MulticastReader;
fn main() {
    let args : Vec<String> = std::env::args().collect();
    if args.len() < 3 {
        println!("Usage: {} multicast_ip multicast_port", args[0]);
        return;
    }
    let port : u16 = std::str::FromStr::from_str(args[2].as_str()).unwrap();
    println!("Connecting to {}:{}", args[1], port);
    let mut reader = MulticastReader::new((args[1].as_str(), port)).unwrap();
    loop {
        match reader.try_read() {
            Ok(value) => println!("{}", String::from_utf8(value).unwrap()),
            Err(..) => break,
        }
    }
}