文件名称:功能丰富的便携式异步通道库
文件大小:441KB
文件格式:ZIP
更新时间:2024-07-18 12:29:50
rust asynchronous channels
功能丰富、可移植的异步通道库>crates.io >docs.rs为什么要使用邮资?包括丰富的频道。|障碍|广播|派送|mpsc|一次性|手表适用于任何执行程序。目前回归是为tokio和async-std编写的。通过futures-traits特性,通道实现了期货Sink/Stream特征。经过彻底测试。通道具有完整的单元测试覆盖率,以及具有多个异步执行器的集成测试覆盖率。包括内置的Sink和Stream组合器。接收器可以链接和过滤。流可以被链接、过滤、映射和合并。接收器和流可以记录它们的值,以便于应用程序调试。频道邮费::屏障屏障通道可用于同步事件,但不传输任何数据。当发送方掉线(或tx.send(()) )时,接收方被唤醒。这可用于在任务之间异步协调操作。邮费::广播广播信道在多个发送方和多个接收方之间提供可靠的广播传送。通道具有固定容量,如果缓冲区已满,则发送方将暂停。当接收器被克隆时,两个接收器都将被发送相同系列的消息。发送者还提供了一个subscribe()方法,该方法创建了一个接收者,该方法将观察在调用订阅后发送的所有消息。邮费::发货调度通道提供多发送方、多接收方的消息调
【文件预览】:
postage-rs-main
----.github()
--------workflows()
----LICENSE(1KB)
----src()
--------logging.rs(477B)
--------prelude.rs(98B)
--------test.rs(498B)
--------test()
--------stream.rs(9KB)
--------sink()
--------sync.rs(4KB)
--------sink.rs(9KB)
--------sync()
--------lib.rs(2KB)
--------channels.rs(732B)
--------stream()
--------futures.rs(8KB)
--------channels()
--------context.rs(1KB)
----Cargo.toml(2KB)
----benches()
--------tokio_watch.rs(1KB)
--------dispatch.rs(1KB)
--------async_std_channel.rs(1KB)
--------tokio_broadcast.rs(1KB)
--------tokio_mpsc.rs(1KB)
--------broadcast.rs(1KB)
--------mpsc.rs(1KB)
--------watch.rs(789B)
----.gitignore(34B)
----readme()
--------Postage Banner.png(19KB)
--------postage-banner.svg(607KB)
--------Postage Blog Banner.png(39KB)
--------Postage Blog Banner.svg(612KB)
----README.md(4KB)