transform-stream 0.1.2

Lightweight async stream wrapper
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40

# transform-stream

[![Crates.io][crates-badge]][crates-url]
[![MIT licensed][mit-badge]][mit-url]
[![Docs][docs-badge]][docs-url]
![CI][ci-badge]
[![Unsafe Forbidden][unsafe-forbidden-badge]][unsafe-forbidden-url]

[crates-badge]: https://img.shields.io/crates/v/transform-stream.svg
[crates-url]: https://crates.io/crates/transform-stream
[mit-badge]: https://img.shields.io/badge/license-MIT-blue.svg
[mit-url]: LICENSE
[docs-badge]: https://docs.rs/transform-stream/badge.svg
[docs-url]: https://docs.rs/transform-stream/
[ci-badge]: https://github.com/Nugine/transform-stream/workflows/CI/badge.svg
[unsafe-forbidden-badge]: https://img.shields.io/badge/unsafe-forbidden-success.svg
[unsafe-forbidden-url]: https://github.com/rust-secure-code/safety-dance/

Lightweight async stream wrapper.

## Usage

```rust
use transform_stream::{try_stream, AsyncTryStream};
use futures::StreamExt;
use std::io;

let stream: AsyncTryStream<Vec<u8>, io::Error, _> = try_stream!{
    yield_!(vec![b'1', b'2']);
    yield_!(vec![b'3', b'4']);
    Ok(())
};

futures::executor::block_on(async {
    futures::pin_mut!(stream);
    assert_eq!(stream.next().await.unwrap().unwrap(), vec![b'1', b'2']);
    assert_eq!(stream.next().await.unwrap().unwrap(), vec![b'3', b'4']);
    assert!(stream.next().await.is_none());
});
```