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 • Rust 包仓库 427/week @ 2024-03-14 • Rust 包仓库 254/week @ 2024-03-21 • Rust 包仓库 666/week @ 2024-03-28 • Rust 包仓库 435/week @ 2024-04-04 • Rust 包仓库 573/week @ 2024-04-11 • Rust 包仓库 443/week @ 2024-04-18 • Rust 包仓库 508/week @ 2024-04-25 • Rust 包仓库 376/week @ 2024-05-02 • Rust 包仓库 421/week @ 2024-05-09 • Rust 包仓库 531/week @ 2024-05-16 • Rust 包仓库 417/week @ 2024-05-23 • Rust 包仓库 465/week @ 2024-05-30 • Rust 包仓库 422/week @ 2024-06-06 • Rust 包仓库 975/week @ 2024-06-13 • Rust 包仓库 989/week @ 2024-06-20 • Rust 包仓库 633/week @ 2024-06-27 • Rust 包仓库

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