#stream #io-stream #buffer #io

bytes-stream

Utility functions to work with stream of bytes

3 releases

0.0.3 May 14, 2023
0.0.2 Apr 1, 2023
0.0.1 Apr 1, 2023

#2035 in Asynchronous

Download history 25/week @ 2024-10-29 72/week @ 2024-11-05 66/week @ 2024-11-12 122/week @ 2024-11-19 64/week @ 2024-11-26 46/week @ 2024-12-03 73/week @ 2024-12-10 51/week @ 2024-12-17 1/week @ 2025-01-07 101/week @ 2025-01-14 79/week @ 2025-01-21 24/week @ 2025-01-28 61/week @ 2025-02-04 16/week @ 2025-02-11

214 downloads per month

MIT license

21KB
385 lines

bytes-stream

Utility functions to work with Streams of Bytes.

Examples

Split a stream of bytes into chunks:

use bytes::Bytes;
use bytes_stream::BytesStream;
use futures::StreamExt;

fn main() {
    futures::executor::block_on(async {
        let stream = futures::stream::iter(vec![
            Bytes::from_static(&[1, 2, 3]),
            Bytes::from_static(&[4, 5, 6]),
            Bytes::from_static(&[7, 8, 9]),
        ]);

        let mut stream = stream.bytes_chunks(4);

        assert_eq!(stream.next().await, Some(Bytes::from_static(&[1, 2, 3, 4])));
        assert_eq!(stream.next().await, Some(Bytes::from_static(&[5, 6, 7, 8])));
        assert_eq!(stream.next().await, Some(Bytes::from_static(&[9])));
        assert_eq!(stream.next().await, None);
    });
}

Dependencies

~215–290KB