async-utf8-decoder

Asynchronous and incremental UTF-8 decoder

async-utf8-decoder crate provides Utf8Decoder which allows to convert any object which implements AsyncRead trait into a string stream which implements Stream trait.

Example

```rust use futures::io; use futures::channel::mpsc; use asyncutf8decoder::Utf8Decoder;

let (mut tx, rx) = mpsc::unbounded::>>(); let mut decoder = Utf8Decoder::new(rx.intoasyncread());

tx.send(Ok(vec![240])).await?; assert!(timeout(decoder.next()).await.iserr()); tx.send(Ok(vec![159])).await?; assert!(timeout(decoder.next()).await.iserr()); tx.send(Ok(vec![146])).await?; assert!(timeout(decoder.next()).await.iserr()); tx.send(Ok(vec![150])).await?; asserteq!("💖", timeout(decoder.next()).await?.unwrap()?); assert!(timeout(decoder.next()).await.is_err()); ```

License

The code follows MIT license written in LICENSE. Contributors need to agree that any modifications sent in this repository follow the license.