Ok(Either::A((_x, _b))) => {

                Ok(Either::A((_x, b))) => {

                    future::ok(future::Loop::Break(()))

                    future::ok(future::Loop::Break(b.into_inner()))

                Err(Either::A((e, _b))) => {

                Err(Either::A((e, b))) => {

                    future::ok(future::Loop::Break(()))

                    future::ok(future::Loop::Break(b.into_inner()))

    }).and_then(|opt_cmd_recv: Option<Receiver<XmppCommand>>| {
        if let Some(mut cmd_recv) = opt_cmd_recv {
            // process left commands
            info!("Stop accepting commands");
            cmd_recv.close();
            Box::new(cmd_recv.for_each(|_cmd| future::ok(())).map_err(|_| {
                tokio::io::Error::new(tokio::io::ErrorKind::Other, "cmd receiver last error")
            })) as Box<Future<Item = (), Error = tokio::io::Error>>
        } else {
            Box::new(future::err(tokio::io::Error::new(
                tokio::io::ErrorKind::Other,
                "cmd receiver gone",
            )))
        }