#![crate_name = "tasksink"]
use std::io::{self, Write};
use std::time::Instant;
fn main() {
let context = zmq2::Context::new();
let receiver = context.socket(zmq2::PULL).unwrap();
assert!(receiver.bind("tcp://*:5558").is_ok());
receiver.recv_bytes(0).unwrap();
let start = Instant::now();
for task_nbr in 0..100 {
receiver.recv_bytes(0).unwrap();
if task_nbr % 10 == 0 {
print!(":");
} else {
print!(".");
}
let _ = io::stdout().flush();
}
println!("\nTotal elapsed time: {:?}", start.elapsed());
}