Struct FutureBool

pub struct FutureBool { /* private fields */ }

A bool one can await the changes.

Implementations

impl FutureBool

pub fn new(val: bool) -> Self

Creates a new FutureBool with some initial value.

Examples found in repository

examples/ex1.rs (line 11)

async fn main() {
    let b: FutureBool = FutureBool::new(false);
    let mut tasks = Vec::new();

    for x in 0..20 {
        let clone = b.clone();
        if x % 2 == 0 {
            tasks.push(tokio::spawn(async move {
                clone.wait_true().await;
                eprintln!("{:2}: Yess", x);
            }));
        } else {
            tasks.push(tokio::spawn(async move {
                clone.wait_false().await;
                eprintln!("{:2}: Nope", x);
            }));
        }
    }

    sleep!(2);
    b.set();

    for task in tasks {
        let _ = task.await;
    }
}

pub fn set(&self)

Sets the bool value to true.

Examples found in repository

examples/ex1.rs (line 30)

async fn main() {
    let b: FutureBool = FutureBool::new(false);
    let mut tasks = Vec::new();

    for x in 0..20 {
        let clone = b.clone();
        if x % 2 == 0 {
            tasks.push(tokio::spawn(async move {
                clone.wait_true().await;
                eprintln!("{:2}: Yess", x);
            }));
        } else {
            tasks.push(tokio::spawn(async move {
                clone.wait_false().await;
                eprintln!("{:2}: Nope", x);
            }));
        }
    }

    sleep!(2);
    b.set();

    for task in tasks {
        let _ = task.await;
    }
}

pub fn unset(&self)

Sets the bool value to false.

pub async fn wait_change(&self) -> bool

Returns the new value when it has changed.

pub async fn wait_true(&self)

If the value is true, returns immidiately, otherwise waits until it’s true.

Examples found in repository

examples/ex1.rs (line 18)

async fn main() {
    let b: FutureBool = FutureBool::new(false);
    let mut tasks = Vec::new();

    for x in 0..20 {
        let clone = b.clone();
        if x % 2 == 0 {
            tasks.push(tokio::spawn(async move {
                clone.wait_true().await;
                eprintln!("{:2}: Yess", x);
            }));
        } else {
            tasks.push(tokio::spawn(async move {
                clone.wait_false().await;
                eprintln!("{:2}: Nope", x);
            }));
        }
    }

    sleep!(2);
    b.set();

    for task in tasks {
        let _ = task.await;
    }
}

pub async fn wait_false(&self)

If the value is false, returns immidiately, otherwise waits until it’s false.

Examples found in repository

examples/ex1.rs (line 23)

async fn main() {
    let b: FutureBool = FutureBool::new(false);
    let mut tasks = Vec::new();

    for x in 0..20 {
        let clone = b.clone();
        if x % 2 == 0 {
            tasks.push(tokio::spawn(async move {
                clone.wait_true().await;
                eprintln!("{:2}: Yess", x);
            }));
        } else {
            tasks.push(tokio::spawn(async move {
                clone.wait_false().await;
                eprintln!("{:2}: Nope", x);
            }));
        }
    }

    sleep!(2);
    b.set();

    for task in tasks {
        let _ = task.await;
    }
}

Trait Implementations

impl Clone for FutureBool

fn clone(&self) -> FutureBool

Returns a duplicate of the value.

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

Performs copy-assignment from source.