use std::io;

use zedmq::prelude::*;

fn main() -> io::Result<()> {
    let address = std::env::var("ADDRESS").unwrap();
    let mut socket: Pull = zedmq::connect("tcp", address.as_str()).unwrap();

    while let Ok(message) = socket.recv() {
        dbg!(message);
    }

    Ok(())
}