Remove Sync
This commit is contained in:
committed by
Martin Algesten
parent
5e00b5c5e3
commit
5801f87c56
@@ -288,7 +288,7 @@ impl Response {
|
|||||||
/// assert_eq!(bytes.len(), len);
|
/// assert_eq!(bytes.len(), len);
|
||||||
/// # }
|
/// # }
|
||||||
/// ```
|
/// ```
|
||||||
pub fn into_reader(self) -> impl Read + Send + Sync {
|
pub fn into_reader(self) -> impl Read + Send {
|
||||||
//
|
//
|
||||||
let is_http10 = self.http_version().eq_ignore_ascii_case("HTTP/1.0");
|
let is_http10 = self.http_version().eq_ignore_ascii_case("HTTP/1.0");
|
||||||
let is_close = self
|
let is_close = self
|
||||||
@@ -327,7 +327,7 @@ impl Response {
|
|||||||
|
|
||||||
match (use_chunked, limit_bytes) {
|
match (use_chunked, limit_bytes) {
|
||||||
(true, _) => Box::new(PoolReturnRead::new(unit, ChunkDecoder::new(stream)))
|
(true, _) => Box::new(PoolReturnRead::new(unit, ChunkDecoder::new(stream)))
|
||||||
as Box<dyn Read + Send + Sync>,
|
as Box<dyn Read + Send>,
|
||||||
(false, Some(len)) => {
|
(false, Some(len)) => {
|
||||||
Box::new(PoolReturnRead::new(unit, LimitedRead::new(stream, len)))
|
Box::new(PoolReturnRead::new(unit, LimitedRead::new(stream, len)))
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user