fn online(self) -> impl Future<Item = XmppConnection, Error = std::rc::Rc<config::Account>> {
        Box::new(future::loop_fn(
            (self.inner, self.account),
            |(client, account)| {
                client.into_future().then(|r| match r {
                    Ok((event, client)) => match event {
                        Some(Event::Online) => {
                            info!("Online");
                            future::ok(future::Loop::Break(XmppConnection {
                                account,
                                inner: client,
                            }))
                        }
                        Some(Event::Stanza(s)) => {
                            info!("xmpp stanza: {:?}", s);
                            future::ok(future::Loop::Continue((client, account)))
                        }
                        _ => {
                            warn!("Disconnected");
                            future::err(account)
                        }
                    },
                    Err((e, _)) => {
                        error!("xmpp receive error: {}", e);

    fn online(self) -> impl Future<Item = Self, Error = std::rc::Rc<config::Account>> {
        future::loop_fn((self.inner, self.account), |(client, account)| {
            client.into_future().then(|r| match r {
                Ok((event, client)) => match event {
                    Some(Event::Online) => {
                        info!("Online");
                        future::ok(future::Loop::Break(XmppConnection {
                            account,
                            inner: client,
                        }))
                    }
                    Some(Event::Stanza(s)) => {
                        info!("xmpp stanza: {:?}", s);
                        future::ok(future::Loop::Continue((client, account)))
                    }
                    _ => {
                        warn!("Disconnected");

                })
            },
        ))

                },
                Err((e, _)) => {
                    error!("xmpp receive error: {}", e);
                    future::err(account)
                }
            })
        })