1#![crate_name = "hwserver"]
2extern crate zmq_rs as zmq;
3
4use std::time::Duration;
5use std::thread::sleep;
6
7fn main() {
8 let mut context = zmq::Context::new().unwrap();
9 let mut responder = context.socket(zmq::REP).unwrap();
10 responder.bind("tcp://*:5555").unwrap();
11
12 loop {
13 let mut buffer: Vec<u8> = Vec::with_capacity(10);
14 responder.recv_bytes_into_slice(&mut buffer, 0).unwrap();
15 println!("Received Hello");
16 sleep(Duration::from_secs(1));
17 responder.send_bytes("World".as_bytes(), 0).unwrap();
18 }
19}