[][src]Struct frappe::futures::StreamFuture

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

A future that waits for a stream value.

This is created by Stream::next.

Methods

impl<T: Clone + Send + 'static> StreamFuture<T>[src]

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

Obtains the source stream.

pub fn reload(&self)[src]

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> Unpin for StreamFuture<T>[src]

impl<T: Debug> Debug for StreamFuture<T>[src]

impl<T> Future for StreamFuture<T>[src]

type Output = T

The type of value produced on completion.

Auto Trait Implementations

impl<T> Send for StreamFuture<T> where
    T: Send

impl<T> Sync for StreamFuture<T> where
    T: Send

impl<T> !UnwindSafe for StreamFuture<T>

impl<T> !RefUnwindSafe for StreamFuture<T>

Blanket Implementations

impl<T> From<T> for T[src]

impl<T, U> Into<U> for T where
    U: From<T>, 
[src]

impl<T, U> TryFrom<U> for T where
    U: Into<T>, 
[src]

type Error = Infallible

The type returned in the event of a conversion error.

impl<T, U> TryInto<U> for T where
    U: TryFrom<T>, 
[src]

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

impl<T> Borrow<T> for T where
    T: ?Sized
[src]

impl<T> BorrowMut<T> for T where
    T: ?Sized
[src]

impl<T> Any for T where
    T: 'static + ?Sized
[src]

impl<T> Erased for T