let (sink, stream) = client.split();
                Box::new(future::loop_fn(
                    (sink, stream, account),
                    |(sink, stream, account)| {
                        stream.into_future().then(|r| match r {
                            Ok((event, stream)) => match event {
                                Some(Event::Online) => {
                                    info!("Online");
                                    future::ok(future::Loop::Break(future::Loop::Break(
                                        XmppConnection {
                                            account,
                                            inner: Some((sink, stream)),
                                        },
                                    )))
                                }
                                Some(Event::Stanza(s)) => {
                                    info!("xmpp stanza: {:?}", s);
                                    future::ok(future::Loop::Continue((sink, stream, account)))
                                }
                                _ => {
                                    warn!("Disconnected");
                                    future::ok(future::Loop::Break(future::Loop::Continue(account)))
                                }
                            },
                            Err((e, _)) => {
                                error!("xmpp receive error: {}", e);
                                future::ok(future::Loop::Break(future::Loop::Continue(account)))
                            }
                        })
                    },
                ))

                Self::online(client.split(), account).then(|r| match r {
                    Ok(conn) => future::ok(future::Loop::Break(conn)),
                    Err(acc) => future::ok(future::Loop::Continue(acc)),
                })

    }
    /// get connection and wait for online status and set presence
    /// returns error if something went wrong
    fn online(
        (sink, stream): (stream::SplitSink<Client>, stream::SplitStream<Client>),
        account: config::Account,
    ) -> impl Future<Item = XmppConnection, Error = config::Account> {
        Box::new(future::loop_fn(
            (sink, stream, account),
            |(sink, stream, account)| {
                stream.into_future().then(|r| match r {
                    Ok((event, stream)) => match event {
                        Some(Event::Online) => {
                            info!("Online");
                            future::ok(future::Loop::Break(XmppConnection {
                                account,
                                inner: Some((sink, stream)),
                            }))
                        }
                        Some(Event::Stanza(s)) => {
                            info!("xmpp stanza: {:?}", s);
                            future::ok(future::Loop::Continue((sink, stream, account)))
                        }
                        _ => {
                            warn!("Disconnected");
                            future::err(account)
                        }
                    },
                    Err((e, _)) => {
                        error!("xmpp receive error: {}", e);
                        future::err(account)
                    }
                })
            },
        ))