文件名称:async-zmq:ZeroMQ 绑定的异步版本
文件大小:35KB
文件格式:ZIP
更新时间:2024-06-19 09:23:19
Rust
ZeroMQ 绑定的异步版本 Async-zmq 是以异步方式的高级绑定,与每个异步运行时兼容。 无需配置或调整功能。 只需插入并查看它是如何工作的! 用法 用户可以简单地使用async_zmq::*初始化任何套接字类型,然后根据您的场景调用bind()或connect 。 例如,如果有人想要一个发布套接字,那么他可以像这样初始化套接字: let zmq = async_zmq::publish("tcp://127.0.0.1:5555")?.bind(); 如果需要在不同的套接字之间共享上下文,我们可以在构建套接字时进行设置: let context = Context::new(); let xpub = async_zmq::xpublish("inproc://example")?.with_context(&context).bind(); let sub = sub
【文件预览】:
async-zmq-master
----.gitignore(18B)
----src()
--------pull.rs(2KB)
--------reply.rs(3KB)
--------pair.rs(3KB)
--------socket.rs(6KB)
--------xsubscribe.rs(3KB)
--------stream.rs(2KB)
--------xpublish.rs(3KB)
--------subscribe.rs(3KB)
--------dealer.rs(3KB)
--------errors.rs(13KB)
--------push.rs(3KB)
--------publish.rs(3KB)
--------reactor()
--------request.rs(3KB)
--------router.rs(3KB)
--------lib.rs(3KB)
----Cargo.toml(726B)
----.github()
--------workflows()
----examples()
--------reply.rs(480B)
--------request.rs(408B)
----LICENSE-MIT(1KB)
----README.md(2KB)
----tests()
--------pub_sub.rs(1KB)
--------request_reply.rs(781B)
--------xpub.rs(859B)
--------push_pull.rs(1KB)
----LICENSE-APACHE(11KB)