We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent da5cec5 commit 0b06d1cCopy full SHA for 0b06d1c
src/client/client_request.rs
@@ -27,7 +27,6 @@ use futures_util::io;
27
use reqwest::Method;
28
use serde::de::DeserializeOwned;
29
use serde::{Deserialize, Serialize};
30
-use std::pin::Pin;
31
use tokio::io::{AsyncBufReadExt, BufReader};
32
use tokio_stream::wrappers::LinesStream;
33
use tokio_util::io::StreamReader;
@@ -100,7 +99,7 @@ pub trait StreamingRequest: ClientRequest {
100
99
101
fn build_stream(
102
response: reqwest::Response,
103
- ) -> Pin<Box<impl Stream<Item = Result<Self::ItemType, ClientError>>>> {
+ ) -> impl Stream<Item = Result<Self::ItemType, ClientError>> {
104
Box::pin(
105
Self::lines_stream(response)
106
.map(|line| {
0 commit comments