Struct StreamFuture 

pub struct StreamFuture<T> { /* private fields */ }

A future that waits for a stream value.

This is created by Stream::next.

Implementations

impl<T: Clone + Send + 'static> StreamFuture<T>

pub fn get_source(&self) -> &Stream<T>

Obtains the source stream.

pub fn reload(&self)

Reuses a finished future so it can wait for another value.

Normally calling poll on a future after it returned Poll::Ready will panic. This method will restart this future so it can be polled again for another value. This allows awaiting for multiple values without having to create and allocate multiple future objects.

Calling this on a pending (or ready but unread) future will have no effect.

Trait Implementations

impl<T: Debug> Debug for StreamFuture<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T> Future for StreamFuture<T>

type Output = T

The type of value produced on completion.

fn poll(self: Pin<&mut Self>, ctx: &mut Context<'_>) -> Poll<Self::Output>

Attempts to resolve the future to a final value, registering the current task for wakeup if the value is not yet available.

impl<T> Unpin for StreamFuture<T>