use threadpool::ThreadPool;
use futures::executor::block_on;
use rand::Rng;


use std::{
    future::Future,
    // pin::Pin,
    // sync::{Arc, Mutex},
    // task::{Context, Poll},
    // thread,
    // time::Duration,
};
use futures::TryStreamExt;

struct MyFuture ;

impl MyFuture {
    pub async fn call (&mut self) -> std::result::Result<std::string::String, std::string::String> {
        println!("poll called");
        let mut rng = rand::thread_rng();
        let i: i32 = rng.gen_range(0, 10);
        if i < 5 {
          Ok("success".to_string())
        } else {
          Err("failure".to_string())
        }
    }
}

async fn get_future() ->  Result<(), ()> {
    (MyFuture{}).call().await.map(|res| {
        println!("{}", res);
    }).map_err(|err| {
        println!("{}", err);
    })
}

pub fn fu_test() {

    let future = get_future();
    // ThreadPool::new(4).execute(future);
    block_on(future);
}