diff --git a/src/async_impl/multipart.rs b/src/async_impl/multipart.rs index 75198ca0a..35f182488 100644 --- a/src/async_impl/multipart.rs +++ b/src/async_impl/multipart.rs @@ -155,7 +155,7 @@ impl Form { // then append form data followed by terminating CRLF boundary .chain(header) - .chain(part.value.into_stream()) + .chain(part.value) .chain(stream::once(future::ready(Ok("\r\n".into())))) } @@ -538,7 +538,7 @@ mod tests { .enable_all() .build() .expect("new rt"); - let body = form.stream().into_stream(); + let body = form.stream(); let s = body.map_ok(|try_c| try_c.to_vec()).try_concat(); let out = rt.block_on(s); @@ -588,7 +588,7 @@ mod tests { .enable_all() .build() .expect("new rt"); - let body = form.stream().into_stream(); + let body = form.stream(); let s = body.map(|try_c| try_c.map(|r| r.to_vec())).try_concat(); let out = rt.block_on(s).unwrap(); @@ -620,7 +620,7 @@ mod tests { .enable_all() .build() .expect("new rt"); - let body = form.stream().into_stream(); + let body = form.stream(); let s = body.map(|try_c| try_c.map(|r| r.to_vec())).try_concat(); let out = rt.block_on(s).unwrap();