#frame #pipe #framed #byte #mpsc

framed_pipe

基于 mpsc 的帧管道

1 个不稳定版本

0.1.0 2023 年 8 月 24 日

#8 in #framed

MIT 许可证

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