Struct kitsune_p2p_types::KitsuneTimeout

pub struct KitsuneTimeout(_);

Kitsune Timeout

Implementations

impl KitsuneTimeout

pub fn new(duration: Duration) -> Self

Create a new timeout for duration in the future.

pub fn from_millis(millis: u64) -> Self

Convenience fn to create a new timeout for an amount of milliseconds.

pub fn backoff(&self, initial_ms: u64, max_ms: u64) -> KitsuneBackoff

Generate a backoff instance bound to this timeout

pub fn time_remaining(&self) -> Duration

Get Duration until timeout expires.

pub fn is_expired(&self) -> bool

Has this timeout expired?

pub fn ok(&self, ctx: &str) -> KitsuneResult<()>

Ok(()) if not expired, Err(KitsuneError::TimedOut) if expired.

pub fn mix<'a, 'b, R, F>(
    &'a self,
    ctx: &str,
    f: F
) -> impl Future<Output = KitsuneResult<R>> + 'b + Sendwhere
    R: 'b,
    F: Future<Output = KitsuneResult<R>> + 'b + Send,

Wrap a future with one that will timeout when this timeout expires.

Trait Implementations

impl Clone for KitsuneTimeout

fn clone(&self) -> KitsuneTimeout

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for KitsuneTimeout

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

Formats the value using the given formatter.

impl Copy for KitsuneTimeout