use http::Response;
use http_body_reader::ResponseExt as _;
use http_body_util::{Full, Limited};
#[tokio::main]
async fn main() -> anyhow::Result<()> {
let response = Response::builder().body(Full::new("Lorem ipsum dolor sit amet".as_ref()))?;
let body_reader = response.body_reader().map(|body| Limited::new(body, 8));
assert_eq!(
body_reader.utf8().await.unwrap_err().to_string(),
"length limit exceeded"
);
Ok(())
}