|
|
@ -1,7 +1,6 @@
|
|
|
|
use std::pin::Pin;
|
|
|
|
use std::pin::Pin;
|
|
|
|
|
|
|
|
|
|
|
|
use crate::prelude::*;
|
|
|
|
use crate::stream::{FromStream, IntoStream, Extend};
|
|
|
|
use crate::stream::{FromStream, IntoStream};
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
impl<T> FromStream<T> for Vec<T> {
|
|
|
|
impl<T> FromStream<T> for Vec<T> {
|
|
|
|
#[inline]
|
|
|
|
#[inline]
|
|
|
@ -17,9 +16,7 @@ impl<T> FromStream<T> for Vec<T> {
|
|
|
|
pin_utils::pin_mut!(stream);
|
|
|
|
pin_utils::pin_mut!(stream);
|
|
|
|
|
|
|
|
|
|
|
|
let mut out = vec![];
|
|
|
|
let mut out = vec![];
|
|
|
|
while let Some(item) = stream.next().await {
|
|
|
|
out.stream_extend(stream).await;
|
|
|
|
out.push(item);
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
out
|
|
|
|
out
|
|
|
|
}))
|
|
|
|
}))
|
|
|
|
}
|
|
|
|
}
|
|
|
|