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
import zmq
import os

ctx = zmq.Context()
s = ctx.socket(zmq.PULL)
s.bind(st := f"tcp://{os.environ['ADDRESS']}")

import time

while True:
    print(s.recv_multipart())