Struct CoroWorker 

pub struct CoroWorker<T, E> { /* private fields */ }

🧵 ⬡ Represents a single-thread stackless coroutine worker.

---

^{📍 work/task/coro}

---

It has a private status that can be either running or halted.

Implementations

impl<T, E> CoroWorker<T, E>

pub fn yield_ok(&mut self, value: T) -> CoroWork<'_, T, E>

Yields an Ok value and returns an awaitable CoroWork.

Examples found in repository

examples/work/coro_manager.rs (line 15)

fn main() {
    let mut cr = CoroManager::<char, String>::new();

    for i in 1..=3 {
        cr.push(|mut c| async move {
            println!("> instance {i} NEW");

            let mut count = 0;
            loop {
                let res = c.yield_ok('a').await?;
                println!("  instance {i} A.{count} {res:?})");

                let _res = c.yield_ok('b').await?;
                println!("  instance {i} B {_res:?}");

                if count > 2 {
                    break;
                }
                count += 1;
            }

            println!("  instance {i} BYE!");

            if i == 2 { serr(format!["instance {i} produced an error"]) } else { sok('x') }
        });
    }
    cr.push(|mut c| async move {
        println!("> instance 4 NEW");
        for _n in 0..3 {
            let _res = c.yield_err(format!["custom err"]).await?;
        }
        println!("  instance 4 BYE!");
        None
    });

    println!("Running");
    cr.run();
    println!("Done");
}

pub fn yield_err(&mut self, error: E) -> CoroWork<'_, T, E>

Yields an Err and returns an awaitable CoroWork.

Examples found in repository

examples/work/coro_manager.rs (line 35)

fn main() {
    let mut cr = CoroManager::<char, String>::new();

    for i in 1..=3 {
        cr.push(|mut c| async move {
            println!("> instance {i} NEW");

            let mut count = 0;
            loop {
                let res = c.yield_ok('a').await?;
                println!("  instance {i} A.{count} {res:?})");

                let _res = c.yield_ok('b').await?;
                println!("  instance {i} B {_res:?}");

                if count > 2 {
                    break;
                }
                count += 1;
            }

            println!("  instance {i} BYE!");

            if i == 2 { serr(format!["instance {i} produced an error"]) } else { sok('x') }
        });
    }
    cr.push(|mut c| async move {
        println!("> instance 4 NEW");
        for _n in 0..3 {
            let _res = c.yield_err(format!["custom err"]).await?;
        }
        println!("  instance 4 BYE!");
        None
    });

    println!("Running");
    cr.run();
    println!("Done");
}

Trait Implementations

impl<T: Clone, E: Clone> Clone for CoroWorker<T, E>

fn clone(&self) -> CoroWorker<T, E>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Copy, E: Copy> Copy for CoroWorker<T, E>

impl<T: Debug, E: Debug> Debug for CoroWorker<T, E>

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

Formats the value using the given formatter.