Struct streamunordered::FinishedStream [−][src]
A stream that has yielded all the items it ever will.
The underlying stream will only be dropped by explicitly removing it from the associated
StreamUnordered
. This method is marked as #[must_use]
to ensure that you either remove the
stream immediately, or you explicitly ask for it to be kept around for later use.
If the FinishedStream
is dropped, the exhausted stream will not be dropped until the owning
StreamUnordered
is.
Implementations
impl FinishedStream
[src]
pub fn remove<S>(self, so: Pin<&mut StreamUnordered<S>>)
[src]
Remove the exhausted stream.
pub fn take<S>(self, so: Pin<&mut StreamUnordered<S>>) -> Option<S> where
S: Unpin,
[src]
S: Unpin,
Take the exhausted stream.
Note that this requires S: Unpin
since it moves the stream even though it has already
been pinned by StreamUnordered
.
pub fn keep(self)
[src]
Leave the exhausted stream in the StreamUnordered
.
This allows you to continue to access the stream through StreamUnordered::get_mut
and
friends should you need to perform further operations on it (e.g., if it is also being used
as a Sink
). Note that the stream will then not be dropped until you explicitly remove
or take
it from the StreamUnordered
.
pub fn token(self) -> usize
[src]
Return the token associated with the exhausted stream.
Auto Trait Implementations
impl RefUnwindSafe for FinishedStream
[src]
impl Send for FinishedStream
[src]
impl Sync for FinishedStream
[src]
impl Unpin for FinishedStream
[src]
impl UnwindSafe for FinishedStream
[src]
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
pub fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,