16 releases (6 breaking)

0.7.0 Jan 19, 2022
0.6.1 Oct 28, 2021
0.5.1 Oct 15, 2021
0.4.1 Oct 15, 2021
0.1.2 Nov 12, 2019

#623 in Asynchronous

Download history 13480/week @ 2024-07-07 13272/week @ 2024-07-14 14658/week @ 2024-07-21 14195/week @ 2024-07-28 14488/week @ 2024-08-04 12566/week @ 2024-08-11 13438/week @ 2024-08-18 16836/week @ 2024-08-25 13090/week @ 2024-09-01 9499/week @ 2024-09-08 9618/week @ 2024-09-15 10625/week @ 2024-09-22 8774/week @ 2024-09-29 11433/week @ 2024-10-06 11650/week @ 2024-10-13 11829/week @ 2024-10-20

44,207 downloads per month
Used in 34 crates (6 directly)

MIT/Apache

24KB
386 lines

stop-token

Cooperative cancellation for async Rust

See crate docs for details

You can use this crate to create a deadline received through a StopToken:

use async_std::prelude::*;
use async_std::{stream, task};

use stop_token::prelude::*;
use stop_token::StopSource;

use std::time::Duration;

#[async_std::main]
async fn main() {
    // Create a stop source and generate a token.
    let src = StopSource::new();
    let deadline = src.token();

    // When stop source is dropped, the loop will stop.
    // Move the source to a task, and drop it after 100 millis.
    task::spawn(async move {
        task::sleep(Duration::from_millis(100)).await;
        drop(src);
    });

    // Create a stream that generates numbers until
    // it receives a signal it needs to stop.
    let mut work = stream::repeat(12u8).timeout_at(deadline);

    // Loop over each item in the stream.
    while let Some(Ok(ev)) = work.next().await {
        println!("{}", ev);
    }
}

Or Instant to create a time-based deadline:

use async_std::prelude::*;
use async_std::stream;

use stop_token::prelude::*;

use std::time::{Instant, Duration};

#[async_std::main]
async fn main() {
    // Create a stream that generates numbers for 100 millis.
    let deadline = Instant::now() + Duration::from_millis(100);
    let mut work = stream::repeat(12u8).timeout_at(deadline);

    // Loop over each item in the stream.
    while let Some(Ok(ev)) = work.next().await {
        println!("{}", ev);
    }
}

Dependencies

~0.4–11MB
~115K SLoC