Struct sealrs::futures::future::Future

pub struct Future<V: Send + 'static, E: Send + Clone + 'static> {
    pub value: Option<Result<V, E>>,
    // some fields omitted
}

Fields

value: Option<Result<V, E>>

Methods

impl<V: Send + Clone, E: Send + Clone> Future<V, E>

pub fn asyncp<F>(f: F, executor: TSafe<dyn Executor>) -> WrappedFuture<V, E> where
    F: FnMut() -> Result<V, E> + Send + 'static, 

Syntactic sugar for creating of AsyncPromise and extracting it's future

pub fn ok(value: V) -> WrappedFuture<V, E>

Creates already completed future with Ok result

pub fn err(err: E) -> WrappedFuture<V, E>

Creates already completed future with Err result

pub fn new() -> Future<V, E>

pub fn is_completed(&self) -> bool

Return current completion state

pub fn complete(&mut self, result: Result<V, E>)

Fills the value of the futures. This function is called from the promise of which the future belongs and it should never be called by the application code, otherwise it will lead to a breakdown of the future execution logic.

pub fn map<S>(
    &mut self,
    f: Box<dyn FnMut(&V) -> Result<S, E> + Send>
) -> WrappedFuture<S, E> where
    S: Send + Clone + 'static, 

See mirror in WrappedFuture

pub fn recover(
    &mut self,
    f: Box<dyn FnMut(&E) -> Result<V, E> + Send>
) -> WrappedFuture<V, E>

See mirror in WrappedFuture

pub fn flat_map<S>(
    &mut self,
    f: Box<dyn FnMut(&V) -> Result<WrappedFuture<S, E>, E> + Send>
) -> WrappedFuture<S, E> where
    S: Send + Clone + 'static, 

See mirror in WrappedFuture

pub fn map_err<X>(
    &mut self,
    f: Box<dyn FnMut(&E) -> Result<V, X> + Send>
) -> WrappedFuture<V, X> where
    X: Send + Clone + 'static, 

pub fn on_complete(&mut self, f: Box<dyn FnMut(&Result<V, E>) + Send>)

See mirror in WrappedFuture

pub fn ready(&mut self, _timeout: Duration) -> Result<(), Receiver<bool>>

Returns Ok if future is completed of channel wich will be filled when future will be completed