switch-resume 0.1.3

use futures::{future::LocalBoxFuture, prelude::*};

#[derive(Debug)]
enum Action {
    Deeper,
    Back,
}

async fn transition<T>(desc: String, into: impl Future<Output = T>) -> T {
    let transition = async {
        for _ in 0..10 {
            println!("Transition: {desc}");
            tokio::time::sleep(tokio::time::Duration::from_secs_f64(0.1)).await;
        }
    };
    let transition = std::pin::pin!(transition);
    let into = std::pin::pin!(into);
    match futures::future::select(transition, into).await {
        future::Either::Left(((), into)) => into.await,
        future::Either::Right((value, transition)) => {
            #[allow(clippy::let_underscore_future)]
            let _ = transition; // Dont show the rest of transition
            value
        }
    }
}

async fn enter_impl<'a>(
    task: &'a switch_resume::Task<'_, ()>,
    actions: &'a mut dyn Iterator<Item = Action>,
    depth: u16,
) {
    println!("You have now entered depth {depth}");
    while let Some(Action::Deeper) = actions.next() {
        tokio::time::sleep(tokio::time::Duration::from_secs(1)).await;
        transition(
            format!("entering {}", depth + 1),
            enter(task, actions, depth + 1),
        )
        .await;
        println!("Now back to depth {depth}");
        task.switch(move |resume| transition(format!("back to {depth}"), resume(())))
            .await;
    }
    tokio::time::sleep(tokio::time::Duration::from_secs(1)).await;
    println!("You have now exited depth {depth}");
}

fn enter<'a>(
    task: &'a switch_resume::Task<'_, ()>,
    actions: &'a mut dyn Iterator<Item = Action>,
    depth: u16,
) -> LocalBoxFuture<'a, ()> {
    enter_impl(task, actions, depth).boxed_local()
}

#[tokio::main]
async fn main() {
    switch_resume::run(|task| async move {
        enter(
            &task,
            &mut [Action::Deeper, Action::Deeper, Action::Back, Action::Deeper]
                .into_iter()
                .inspect(|action| println!("Performing {action:?}")),
            0,
        )
        .await
    })
    .await;
}