Trait ya_service_bus::timeout::IntoTimeoutFuture[][src]

pub trait IntoTimeoutFuture<D>: Future where
    Self: Future + Sized,
    D: IntoDuration
{ fn timeout(
        self,
        duration: Option<D>
    ) -> Either<Timeout<Self>, Map<Self, fn(_: Self::Output) -> Result<Self::Output, Elapsed>>>; }

Required methods

fn timeout(
    self,
    duration: Option<D>
) -> Either<Timeout<Self>, Map<Self, fn(_: Self::Output) -> Result<Self::Output, Elapsed>>>
[src]

Loading content...

Implementors

impl<F, D> IntoTimeoutFuture<D> for F where
    Self: Future + Sized,
    D: IntoDuration
[src]

Loading content...