This is high-level bindings for zmq in asynchronous manner. Crate itself uses some modules from
async-std, but it should also work on any other async reactor. The goal for this project
is providing simple interface that is compatible with any async executor and reactor.
- PAIR
- PUB
- SUB
- REQ
- REP
- DEALER
- ROUTER
- PULL
- PUSH
- XPUB
- XSUB
- STREAM
- More tests
Users could simply initialize any socket type with async_zmq::* in mind, and then call
bind() or connect depends on your scenario. For example, if someone wants a publish socket,
then he could initialize the socket like this:
let zmq = async_zmq::publish("tcp://127.0.0.1:5555")?.bind();
If there's context need to be shared between different socket, we can set it during building the socket:
let context = Context::new();
let xpub = async_zmq::xpublish("inproc://example")?.with_context(&context).bind();
let sub = subscribe("inproc://example")?.with_context(&context).connect()?;
To learn more about each socket type usage. See modules below.
Prelude module provides some common types, traits and their methods. This crate also re-export so it can be easier for you to import them.
Another common issue when people adopting a library is to deal with its error handling flow.
To prevent introducing more overhead, async_zmq uses the exact same Result/Error type
in zmq crate and re-export them.