Я что-то совсем растерялся: вот у меня есть resp: awc::ClientResponse Далее: let mut

pl = resp.take_payload();
println!("{:?}", pl);
let mut str = pl.into_async_read();
Компилятор говорит:
error[E0277]: actix_web::dev::Payload<Decoder<actix_web::dev::Payload<Pin<Box<dyn futures_util::Stream<Item = Result<actix_web::web::Bytes, PayloadError>>>>>>> doesn't implement std::fmt::Debug
тут вроде все как надо.
А на следующую строчку вдруг:
error[E0271]: type mismatch resolving <actix_web::dev::Payload<Decoder<actix_web::dev::Payload<Pin<Box<dyn futures_util::Stream<Item = Result<actix_web::web::Bytes, PayloadError>>>>>>> as futures_util::Stream>::Item == Result<_, std::io::Error>
Как так? Откуда там внезапно взялся другой тип Error?

Попробуйте сделать MRE (minimal reproducible example) и выложить на play.rust-lang.org

А не прикручен туда ни actix, ни awc...

Тогда нужно скопировать из actix и awc релевантные куски, вырезать лишнее и таки воспроизвести ошибку. Это если конечно вас по-прежнему интересует помощь, потому что иначе можно гадать до следующего президента — не угадаешь 😁.

.

Так, с reqwest в playground тоже ничего не выходит, так как требуется crate feature stream. Но тогда просто вопрос - вот в доках к reqwest::Response к функции bytes_stream() этот Stream вычитывается через цикл с вызовом next(). Это ОК, но меня все еще интересует, почему не срабатывает преобразование этого Stream с помощью, например, .into_async_read() из TryStreamExt и дальше возиться с ним с помощью всяких там комбинаторов из tokio? Не компилируется уже даже это: https://play.rust-lang.org/?version=stable&mode=debug&edition=2021&gist=7416193d53efe490ac4facbbf3da9274

Ладно, сейчас создам проектик. Я так понимаю, зависимости tokio="1" и reqwest="0.11"?

Да.

Вот так будет работать use std::time::Duration; use futures::StreamExt; use reqwest::{Client, Response}; #[tokio::main] async fn main() -> anyhow::Result<()> { let http_client = Client::builder() .connect_timeout(Duration::from_secs(5)) .build()?; let r: Response = http_client.get("http://httpbin.org/get") .send() .await?; let mut stream = r.bytes_stream(); while let Some(item) = stream.next().await { println!("Chunk: {:?}", item?); } Ok(()) } зависимости reqwest = { version = "0.11", default-features = false, features = ["stream"] } tokio = { version = "1", features = ["macros", "rt-multi-thread"] } futures = "0.3"

можно, например, так сделать: let mut pl = r .bytes_stream() .map_err(|err| std::io::Error::new(std::io::ErrorKind::Other, err)) .into_async_read(); .. и надо не забыть при этом включить фичу io в futures-util

Спасибо, но вы будете смеяться, но в этом pl не появляется типа с трейтом AsyncRead. Хотя вроде как должен.

Наверное просто импорта не хватает

возможно вы пробуете использовать токийский AsyncRead? tokio::io::AsyncRead и futures_util::AsyncRead — это разные трейты :)

Там вообще какой-то дикий зоопарк реэспортов, и многие разные типы по факту одинаковые. Но тут, видать, все иначе...