zedmq 0.7.0

A lightweight, safe, pure-Rust ØMQ/ZMTP library implementation.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14

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(())
}