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
15
16
17
18

import zmq
import os

ctx = zmq.Context()

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

import time

while True:
    try:
        s.send(b"oof", flags=zmq.DONTWAIT)
    except zmq.error.Again:
        pass
    finally:
        print(f"oof! ({st})")
        time.sleep(1)