use tokio::prelude::future;
pub fn xmpp_process<F>(signal: F) -> impl future::Future<Item = (), Error = tokio::io::Error>
where
    F: future::Future<Item = ()>,
{
    signal.map_err(|_| tokio::io::Error::new(tokio::io::ErrorKind::Other, "Wrong shutdown signal"))
}

use tokio::prelude::future;

mod xmpp;
use xmpp::xmpp_process;

    let xmpp_join = std::thread::spawn(|| -> Result<(), tokio::io::Error> {

    let xmpp_join = std::thread::spawn(move || -> Result<(), tokio::io::Error> {

        ctrt.block_on(future::ok::<_, tokio::io::Error>(()))

        ctrt.block_on(xmpp_process(ctrl_c.clone().map(|_| ())))