bytes-stream

Utility functions to work with Streams of Bytes.

Examples

Split a stream of bytes into chunks:

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

fn main() { futures::executor::blockon(async { let stream = futures::stream::iter(vec![ Bytes::fromstatic(&[1, 2, 3]), Bytes::fromstatic(&[4, 5, 6]), Bytes::fromstatic(&[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);
});

} ```