10个版本

0.4.0 2023年7月30日
0.3.3 2022年11月14日
0.3.2 2020年5月24日
0.3.1 2020年4月19日
0.0.1 2020年2月19日

#283 in 异步

Download history 427/week @ 2024-03-14 254/week @ 2024-03-21 666/week @ 2024-03-28 435/week @ 2024-04-04 573/week @ 2024-04-11 443/week @ 2024-04-18 508/week @ 2024-04-25 376/week @ 2024-05-02 421/week @ 2024-05-09 531/week @ 2024-05-16 417/week @ 2024-05-23 465/week @ 2024-05-30 422/week @ 2024-06-06 975/week @ 2024-06-13 989/week @ 2024-06-20 633/week @ 2024-06-27

3,095 每月下载量
3 crate 中使用

MIT/Apache

76KB
1K SLoC

ZeroMQ绑定的异步版本

Async-zmq是ZeroMQ的异步级别绑定,与每个异步运行时兼容。无需配置或调整功能。只需连接即可查看其工作方式!

用法

用户可以使用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 = subscribe("inproc://example")?.with_context(&context).connect()?;

由于该crate的使用场景主要是用于发送/接收多部分消息,因此它提供了Multipart,它是用于在实现Stream类型的类型上的接收消息时的类型别名,以及MultipartIter,这是一个泛型结构,可以将任何队列转换为迭代器,然后通过实现Sink类型的类型发送。

有关每个套接字类型的用法,请参阅下面的模块

依赖关系

~1.7–4.5MB
~74K SLoC