Don''t break threads and channel after disconnection

O01eg
Jul 28, 2022, 7:28 AM
EVIOKGS2YYV4SQ2COOC4M76ODWTGN76NX5VNABM2RVSEAJCA6VQAC

Dependencies

Change contents

  • replacement in src/xmpp/xmpp_connection.rs at line 492
    [3.12021][3.12021:12113]()
    pub async fn connect<F>(self, stop_future: F) -> Result<XmppConnection, failure::Error>
    [3.12021]
    [3.12113]
    pub async fn connect<F>(
    self,
    stop_future: F,
    ) -> Result<XmppConnection, (std::rc::Rc<config::Account>, failure::Error)>
  • replacement in src/xmpp/xmpp_connection.rs at line 562
    [3.14698][3.14698:14778]()
    break Err(failure::format_err!("Stop XMPP connection"))
    [3.14698]
    [3.14778]
    break Err((
    account.clone(),
    failure::format_err!("Stop XMPP connection"),
    ))
  • replacement in src/xmpp/xmpp_connection.rs at line 568
    [3.14867][3.14867:14950]()
    break Err(failure::format_err!("Stop XMPP connection(2)"))
    [3.14867]
    [3.14950]
    break Err((
    account.clone(),
    failure::format_err!("Stop XMPP connection(2)"),
    ))
  • replacement in src/xmpp/mod.rs at line 5
    [3.38908][2.87:110]()
    use log::{info, warn};
    [3.38908]
    [3.38938]
    use log::{error, info, warn};
  • replacement in src/xmpp/mod.rs at line 56
    [3.40917][3.40917:40953]()
    Err(e) => break Err(e),
    [3.40917]
    [3.40953]
    Err((acc, e)) => {
    error!("Connection error: {}", e);
    maybe_conn = acc.into();
    }
  • replacement in src/main.rs at line 109
    [3.47665][3.47665:47719]()
    Err(e) => Response::builder()
    [3.47665]
    [3.47719]
    Err(_) => Response::builder()