1 个不稳定版本
0.1.0 | 2023 年 8 月 24 日 |
---|
#8 in #framed
11KB
208 行
FramePipe
基于 MPSC 的用于读写帧的管道,类似于字节上的消息框
示例
let (tx, mut rx) = framed_pipe(n * 2, 4);
let echo_data = vec![vec![0xFF; n], vec![1, 2], vec![], vec![0x0; n / 2]];
for _ in 0..100 {
for data in echo_data.iter() {
tx.clone().try_send(data).expect("send");
}
for data in echo_data.iter() {
let rx_data = rx.next().await.unwrap().expect("rx");
assert_eq!(&rx_data, data.as_slice());
}
}
依赖项
~3–5MB
~84K SLoC