#![feature(async_drop)]

use std::future::{pending, ready};
use std::time::Duration;

use compio::runtime;
use compio::runtime::Runtime;
use futures_util::{select, StreamExt};
use futures_util::FutureExt;
use futures_util::stream::FuturesUnordered;

fn main() {
    Runtime::new().unwrap().block_on(async {
        select! {
            _ = run().fuse() => (),

            _ = compio::time::sleep(Duration::from_millis(100)).fuse() => (),
        }
    })
}

async fn run() {
    runtime::spawn(async {
        let _st = St(1);

        let tasks = runtime::spawn(async {
            let _st = St(2);

            pending::<()>().await
        });

        let futs = FuturesUnordered::new();
        futs.push(tasks);

        futs.for_each(|_| ready(())).await;
    })
    .await
    .unwrap()
}

struct St(usize);

impl Drop for St {
    fn drop(&mut self) {
        println!("drop st {}", self.0);
    }
}