tokio-retry

Extensible, asynchronous retry behaviours based on futures, for the ecosystem of tokio libraries.

Documentation

Installation

Add this to your Cargo.toml:

[dependencies]
tokio-retry = "0.2"

Examples

extern crate futures;
extern crate tokio;
extern crate tokio_retry;

use futures::Future;
use tokio_retry::Retry;
use tokio_retry::strategy::{ExponentialBackoff, jitter};

fn action() -> Result<u64, ()> {
    // do some real-world stuff here...
    Ok(42)
}

fn main() {
    let retry_strategy = ExponentialBackoff::from_millis(10)
        .map(jitter)
        .take(3);

    let future = Retry::spawn(retry_strategy, action).then(|result| {
        println!("result {:?}", result);
        Ok(())
    });

    tokio::run(future);
}