Struct KFuture 

pub struct KFuture<T>
where
    T: Send,
{ /* private fields */ }

A custom future implementation, that can be fulfilled via its paired promise.

Implementations

impl<T> KFuture<T>

where T: Send,

pub fn wait(self) -> T

Wait for the future to be fulfilled and return the value.

This method panics, if there is an error with the link to the promise.

pub fn wait_timeout(self, timeout: Duration) -> Result<T, WaitErr<KFuture<T>>>

Wait for the future to be fulfilled or the timeout to expire.

If the timeout expires, the future itself is returned, so it can be retried later.

impl<T, E> KFuture<Result<T, E>>

where T: Send + Debug, E: Send + Debug,

pub fn wait_expect(self, timeout: Duration, error_msg: &'static str) -> T

Wait for the future to be fulfilled or the timeout to expire.

If the result of the future is an error or the the timeout expires, this method will panic with an appropriate error message.

Trait Implementations

impl<T> Debug for KFuture<T>

where T: Debug + Send,

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

Formats the value using the given formatter.

impl<T> Future for KFuture<T>

where T: Send,

type Output = Result<T, PromiseDropped>

The type of value produced on completion.

fn poll( self: Pin<&mut KFuture<T>>, cx: &mut Context<'_>, ) -> Poll<<KFuture<T> as Future>::Output>

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