异步读取进度

上下文：Rust，async/await，异步读取器。

用于检查 AsyncRead 进度的扩展特质。

支持 futures 0.3 和 tokio 0.2。

许可

根据您的选择，许可如下

• Apache License，版本 2.0，（LICENSE-APACHE 或 https://apache.ac.cn/licenses/LICENSE-2.0）
• MIT 许可证（LICENSE-MIT 或 http://opensource.org/licenses/MIT）

。

贡献

除非您明确声明，否则根据 Apache-2.0 许可证定义的，您有意提交的工作将根据上述方式双重许可，不附加任何额外条款或条件。

lib.rs:

报告异步读取操作的进度

如 Twitter 上所承诺的 链接。

示例

use futures::{
    io::AsyncReadExt,
    stream::{self, TryStreamExt},
};
use async_read_progress::*;

let src = vec![1u8, 2, 3, 4, 5];
let total_size = src.len();
let reader = stream::iter(vec![Ok(src)]).into_async_read();

let mut reader = reader.report_progress(
    /* only call every */ std::time::Duration::from_millis(20),
    |bytes_read| eprintln!("read {}/{}", bytes_read, total_size),
);
#