async-utf8-decoder

异步和增量 UTF-8 解码器

async-utf8-decoder 包提供 Utf8Decoder，允许将实现 AsyncRead 特性的任何对象转换为实现 Stream 特性的字符串流。

示例

use futures::io;
use futures::channel::mpsc;
use async_utf8_decoder::Utf8Decoder;

let (mut tx, rx) = mpsc::unbounded::<io::Result<Vec<u8>>>();
let mut decoder = Utf8Decoder::new(rx.into_async_read());

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

许可证

代码遵循 MIT 许可证，可在 LICENSE 文件中找到。贡献者需要同意在此存储库中发送的任何修改都遵循许可证。