extern crate futures;
extern crate tokio_threadpool;

use self::tokio_threadpool::Builder;
use futures::sync::oneshot;
use futures::Future;
use std::io;

pub fn run<F>(f: F)
where
    F: Future<Item = (), Error = io::Error> + Send + 'static,
{
    let pool = Builder::new().pool_size(1).build();
    let (tx, rx) = oneshot::channel::<()>();
    pool.spawn(f.then(|_| tx.send(())));
    rx.wait().unwrap()
}