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
21

#![feature(convert)]
extern crate diffusion;
use std::path::Path;
use diffusion::Reader;
use diffusion::FileReader;
fn main() {
    let args : Vec<String> = std::env::args().collect();
    if args.len() < 2 {
        println!("Usage: {} dfsn_filename", args[0]);
        return;
    }
    println!("Test started.");
    let mut reader = FileReader::new(&Path::new(args[1].as_str())).unwrap();
    loop {
        match reader.try_read() {
            Ok(value) => println!("{}", String::from_utf8(value).unwrap()),
            Err(..) => break,
        }
    }
    println!("Test finished.");
}