{"header":{"message":"Use shared future for signal everywhere","description":null,"timestamp":"2018-12-29T18:45:16Z","authors":[{"email":"o01eg@yandex.ru","name":"O01eg"}]},"hash":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC","authors":[],"deps":{"hashes":[["AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC","Use shared future for signal everywhere"],["AA",null],["2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC","Create separate functions to process incoming XMPP stanzas"],["OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC","Move online to XmppConnection"],["QWE26TMV6A5VUQLWG5ZMKHMH4NFZIQMVVXQJMPP42JUMM66C3VOQC","update deps"],["TDOR5XQUFRE2LRXML25IJ7A6CIZPFSRES7FQCXDBMIOV4JE2O6OAC","Accept destination"],["ZI4GJ72VMCBV6EQAO4PIKCGXV6ASUYOTGPRVSIGCKDBCDNRQNUFAC","Add message to xmpp command"],["L77O4T7MWBZXKAKH5ZEMWNNACSOZMI42D7VTG4DUFTR4RH5BAXAQC","Formatting and fixes"],["PBRUH4BJGPVY2F4C6SS7F5ZTQJAEBKZVEXCT7EOQRA25DT4MMZEAC","Rename optional XmppConnection to MaybeXmppConnection"],["3GEU7TC7VMBZOSUXQ7II5IGRDGGQCJOLBKFZYUIOGWTKM56ETINQC","Welcome to 2018!"],["5OBTKGDLRGZ4K4373CVGBF53LRECXQ7OW45PW43MJLBU622OKMTQC","Update deps"],["FVVPKFTLD5VOGVDF7MOSSKQ3KPCT4HDGTNTTC6I6B4TWXOTPCJ7AC","Initial commit"],["NDDQQP2PSYH5YNU5EHFRUFACLJURWAHFZQNOIQNJCWHRSB7A3N6QC","Update deps"],["FV6BJ5K64QG63YI2PTII44ZEBAYNJBQZ5FSBHW65EPHGBKFGUW4AC","Send self-presence and store account info in Rc so it willbe used in some future in parallel"],["BTOZT4JPYXPTMXBSKQGXZ3K46UNACE65RIKAGPLUH3OIRVV7WBKAC","Use failure"],["5A5UVGNMHEYI62XUENBEPSRJ7M3MBULYITRDOEYYA5ZDUMFBB6ZQC","Move receiver closing logic out of xmpp processing"],["X6L47BHQPIWFWO53QU6GMRYZC7VPFR4AFTJV7MZIJWIMZG5L65WQC","Use different structure for established xmpp connection"],["FDHRCKH5OM4TONRBQZK5MNKAXTX56LZWVLXEW3QATI5KL4JZO3QQC","Unneded Box"],["O2GM5J4FSOXLTJURP2K6JMCBRAJ2JPJ723A43CR6AT2VQQQYRHFQC","Don't split xmpp receiving and sending"],["VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC","Move XMPP to separate dir"],["EOHEZXX3TBKGJTOMXEPAPHLAJSATRXNY4AIL63BE4VG3HFNWARVQC","Move request processing to structure"]],"deps":["2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC"],"known":["BTOZT4JPYXPTMXBSKQGXZ3K46UNACE65RIKAGPLUH3OIRVV7WBKAC","EOHEZXX3TBKGJTOMXEPAPHLAJSATRXNY4AIL63BE4VG3HFNWARVQC","FDHRCKH5OM4TONRBQZK5MNKAXTX56LZWVLXEW3QATI5KL4JZO3QQC","FVVPKFTLD5VOGVDF7MOSSKQ3KPCT4HDGTNTTC6I6B4TWXOTPCJ7AC","FV6BJ5K64QG63YI2PTII44ZEBAYNJBQZ5FSBHW65EPHGBKFGUW4AC","L77O4T7MWBZXKAKH5ZEMWNNACSOZMI42D7VTG4DUFTR4RH5BAXAQC","NDDQQP2PSYH5YNU5EHFRUFACLJURWAHFZQNOIQNJCWHRSB7A3N6QC","OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC","O2GM5J4FSOXLTJURP2K6JMCBRAJ2JPJ723A43CR6AT2VQQQYRHFQC","PBRUH4BJGPVY2F4C6SS7F5ZTQJAEBKZVEXCT7EOQRA25DT4MMZEAC","QWE26TMV6A5VUQLWG5ZMKHMH4NFZIQMVVXQJMPP42JUMM66C3VOQC","TDOR5XQUFRE2LRXML25IJ7A6CIZPFSRES7FQCXDBMIOV4JE2O6OAC","VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC","X6L47BHQPIWFWO53QU6GMRYZC7VPFR4AFTJV7MZIJWIMZG5L65WQC","ZI4GJ72VMCBV6EQAO4PIKCGXV6ASUYOTGPRVSIGCKDBCDNRQNUFAC","3GEU7TC7VMBZOSUXQ7II5IGRDGGQCJOLBKFZYUIOGWTKM56ETINQC","5A5UVGNMHEYI62XUENBEPSRJ7M3MBULYITRDOEYYA5ZDUMFBB6ZQC","5OBTKGDLRGZ4K4373CVGBF53LRECXQ7OW45PW43MJLBU622OKMTQC"]},"hunks":[{"Edit":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":11,"atom":{"EdgeMap":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":34},"to":{"change":3,"start":34,"end":106},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":434},"to":{"change":3,"start":210,"end":211},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":106},"to":{"change":3,"start":210,"end":211},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":210},"to":{"change":3,"start":210,"end":211},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":3},"to":{"change":3,"start":3,"end":31},"introduced_by":3}],"inode":{"change":3,"pos":17}}},"contents":[{"Del":{"text":" account: std::rc::Rc,","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:76"}},{"Del":{"text":" inner: Option,","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:103"}},{"Del":{"text":"}","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:105"}},{"Del":{"text":"","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:210"}},{"Del":{"text":"pub struct XmppConnection {","pos":"X6L47BHQPIWFWO53QU6GMRYZC7VPFR4AFTJV7MZIJWIMZG5L65WQC:30"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":12,"ins":{"up_context":[{"change":3,"pos":74}],"down_context":[{"change":3,"pos":356}],"flag":"","start":0,"end":77,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":74},"to":{"change":3,"start":107,"end":126},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":375},"to":{"change":3,"start":346,"end":349},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":126},"to":{"change":3,"start":346,"end":349},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":77},"to":{"change":3,"start":346,"end":349},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":346},"to":{"change":3,"start":346,"end":349},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":349},"to":{"change":3,"start":127,"end":356},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":" inner: Option<(stream::SplitSink, stream::SplitStream)>,","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:76"}}],"del_contents":[{"Del":{"text":" inner: Client,","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:125"}},{"Del":{"text":"}","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:347"}},{"Del":{"text":"","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:348"}},{"Del":{"text":"impl From for MaybeXmppConnection {","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:178"}},{"Del":{"text":" fn from(from: XmppConnection) -> MaybeXmppConnection {","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:237"}},{"Del":{"text":" MaybeXmppConnection {","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:267"}},{"Del":{"text":" account: from.account,","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:302"}},{"Del":{"text":" inner: Some(from.inner),","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:339"}},{"Del":{"text":" }","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:349"}},{"Del":{"text":" }","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:355"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":25,"ins":{"up_context":[{"change":3,"pos":579}],"down_context":[{"change":3,"pos":653}],"flag":"","start":78,"end":152,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":579},"to":{"change":3,"start":479,"end":563},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":" fn connect(self) -> impl Future {","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:151"}}],"del_contents":[{"Del":{"text":" fn connect(self) -> impl Future {","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:562"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":30,"ins":{"up_context":[{"change":3,"pos":782}],"down_context":[{"change":3,"pos":944}],"flag":"","start":153,"end":320,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":782},"to":{"change":3,"start":624,"end":744},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":" Box::new(future::ok(MaybeXmppConnection {","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:206"}},{"Add":{"text":" account,","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:231"}},{"Add":{"text":" inner: Some(inner),","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:267"}},{"Add":{"text":" })) as Box>","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:319"}}],"del_contents":[{"Del":{"text":" Box::new(future::ok(XmppConnection { account, inner }))","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:691"}},{"Del":{"text":" as Box>","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:743"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":46,"ins":{"up_context":[{"change":3,"pos":1522}],"down_context":[{"change":3,"pos":1842}],"flag":"","start":321,"end":641,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":1522},"to":{"change":3,"start":745,"end":1142},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":" Self::online(client.split(), account)","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:374"}},{"Add":{"text":" .and_then(Self::self_presence)","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:425"}},{"Add":{"text":" .then(|r| match r {","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:465"}},{"Add":{"text":" Ok(conn) => future::ok(future::Loop::Break(conn)),","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:540"}},{"Add":{"text":" Err(acc) => future::ok(future::Loop::Continue(acc)),","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:617"}},{"Add":{"text":" })","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:640"}}],"del_contents":[{"Del":{"text":" XmppConnection {","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:777"}},{"Del":{"text":" inner: client,","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:812"}},{"Del":{"text":" account,","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:841"}},{"Del":{"text":" }","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:859"}},{"Del":{"text":" .online()","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:885"}},{"Del":{"text":" .and_then(XmppConnection::self_presence)","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:942"}},{"Del":{"text":" .then(|r| match r {","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:978"}},{"Del":{"text":" Ok(conn) => future::ok(future::Loop::Break(conn)),","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:1049"}},{"Del":{"text":" Err(acc) => future::ok(future::Loop::Continue(acc)),","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:1122"}},{"Del":{"text":" })","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:1141"}}]}},{"Edit":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":55,"atom":{"EdgeMap":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":1874},"to":{"change":3,"start":1143,"end":1145},"introduced_by":3}],"inode":{"change":3,"pos":17}}},"contents":[{"Del":{"text":"}","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:1144"}}]}},{"Edit":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":56,"atom":{"EdgeMap":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":1875},"to":{"change":3,"start":1146,"end":1168},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":1168},"to":{"change":2,"start":0,"end":1615},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":2,"pos":1615},"to":{"change":3,"start":533,"end":555},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":3,"pos":533},"to":{"change":3,"start":533,"end":555},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":555},"to":{"change":2,"start":1616,"end":2063},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":2,"pos":2063},"to":{"change":3,"start":736,"end":758},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":3,"pos":736},"to":{"change":3,"start":736,"end":758},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":758},"to":{"change":2,"start":2064,"end":2654},"introduced_by":2}],"inode":{"change":3,"pos":17}}},"contents":[{"Del":{"text":"impl XmppConnection {","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:1167"}},{"Del":{"text":" /// base XMPP processing","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:28"}},{"Del":{"text":" fn xmpp_processing(&mut self, event: &Event) {}","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:80"}},{"Del":{"text":"","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:81"}},{"Del":{"text":" /// process event from xmpp stream","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:120"}},{"Del":{"text":" /// returns from future when condition met","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:167"}},{"Del":{"text":" /// or stop future was resolved","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:203"}},{"Del":{"text":" fn processing(","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:234"}},{"Del":{"text":" self,","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:248"}},{"Del":{"text":" stop_condition: S,","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:275"}},{"Del":{"text":" stop_future: F,","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:299"}},{"Del":{"text":" ) -> impl Future<","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:321"}},{"Del":{"text":" Item = (Self, Result, E>),","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:369"}},{"Del":{"text":" Error = (std::rc::Rc, Result, E>),","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:442"}},{"Del":{"text":" >","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:448"}},{"Del":{"text":" where","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:458"}},{"Del":{"text":" F: Future,","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:498"}},{"Del":{"text":" S: FnMut(&mut Self, &Event) -> bool,","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:543"}},{"Del":{"text":" {","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:549"}},{"Del":{"text":" future::loop_fn(","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:574"}},{"Del":{"text":" (self, stop_future, stop_condition),","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:623"}},{"Del":{"text":" |(xmpp, stop_future, mut stop_condition)| {","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:679"}},{"Del":{"text":" let XmppConnection { inner, account } = xmpp;","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:741"}},{"Del":{"text":" inner.into_future().select2(stop_future).then(|r| match r {","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:817"}},{"Del":{"text":" Ok(Either::A(((event, client), b))) => {","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:878"}},{"Del":{"text":" if let Some(event) = event {","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:931"}},{"Del":{"text":" let mut xmpp = XmppConnection {","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:991"}},{"Del":{"text":" inner: client,","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:1038"}},{"Del":{"text":" account,","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:1079"}},{"Del":{"text":" };","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:1110"}},{"Del":{"text":" xmpp.xmpp_processing(&event);","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:1168"}},{"Del":{"text":" if stop_condition(&mut xmpp, &event) {","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:1235"}},{"Del":{"text":" future::ok(future::Loop::Break((xmpp, Ok(Either::A(b)))))","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:1325"}},{"Del":{"text":" } else {","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:1362"}},{"Del":{"text":" future::ok(future::Loop::Continue((xmpp, b, stop_condition)))","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:1456"}},{"Del":{"text":" }","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:1486"}},{"Del":{"text":" } else {","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:1519"}},{"Del":{"text":" future::err((account, Ok(Either::A(b))))","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:1588"}},{"Del":{"text":" }","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:1614"}},{"Del":{"text":" }","pos":"FDHRCKH5OM4TONRBQZK5MNKAXTX56LZWVLXEW3QATI5KL4JZO3QQC:554"}},{"Del":{"text":" Ok(Either::B((t, a))) => {","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:1662"}},{"Del":{"text":" if let Some(inner) = a.into_inner() {","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:1724"}},{"Del":{"text":" future::ok(future::Loop::Break((","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:1785"}},{"Del":{"text":" XmppConnection { inner, account },","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:1852"}},{"Del":{"text":" Ok(Either::B(t)),","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:1902"}},{"Del":{"text":" )))","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:1934"}},{"Del":{"text":" } else {","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:1967"}},{"Del":{"text":" future::err((account, Ok(Either::B(t))))","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:2036"}},{"Del":{"text":" }","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:2062"}},{"Del":{"text":" }","pos":"FDHRCKH5OM4TONRBQZK5MNKAXTX56LZWVLXEW3QATI5KL4JZO3QQC:757"}},{"Del":{"text":" Err(Either::A((_e, b))) => future::err((account, Ok(Either::A(b)))),","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:2152"}},{"Del":{"text":" Err(Either::B((e, a))) => {","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:2200"}},{"Del":{"text":" if let Some(inner) = a.into_inner() {","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:2262"}},{"Del":{"text":" future::ok(future::Loop::Break((","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:2323"}},{"Del":{"text":" XmppConnection { inner, account },","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:2390"}},{"Del":{"text":" Err(e),","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:2430"}},{"Del":{"text":" )))","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:2462"}},{"Del":{"text":" } else {","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:2495"}},{"Del":{"text":" future::err((account, Err(e)))","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:2554"}},{"Del":{"text":" }","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:2580"}},{"Del":{"text":" }","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:2602"}},{"Del":{"text":" })","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:2621"}},{"Del":{"text":" },","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:2636"}},{"Del":{"text":" )","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:2646"}},{"Del":{"text":" }","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:2652"}},{"Del":{"text":"","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:2653"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":58,"ins":{"up_context":[{"change":2,"pos":2767}],"down_context":[{"change":2,"pos":2865}],"flag":"","start":642,"end":860,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":2,"pos":2767},"to":{"change":2,"start":2767,"end":2865},"introduced_by":2}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":" fn online(","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:656"}},{"Add":{"text":" (sink, stream): (stream::SplitSink, stream::SplitStream),","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:738"}},{"Add":{"text":" account: std::rc::Rc,","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:785"}},{"Add":{"text":" ) -> impl Future> {","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:859"}}],"del_contents":[{"Del":{"text":" fn online(self) -> impl Future> {","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:2864"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":63,"ins":{"up_context":[{"change":2,"pos":2899}],"down_context":[{"change":2,"pos":3086}],"flag":"","start":861,"end":1051,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":2,"pos":2899},"to":{"change":2,"start":2899,"end":3086},"introduced_by":2}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":" (sink, stream, account),","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:897"}},{"Add":{"text":" |(sink, stream, account)| {","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:937"}},{"Add":{"text":" stream.into_future().then(|r| match r {","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:993"}},{"Add":{"text":" Ok((event, stream)) => match event {","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:1050"}}],"del_contents":[{"Del":{"text":" (self.inner, self.account),","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:2938"}},{"Del":{"text":" |(client, account)| {","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:2972"}},{"Del":{"text":" client.into_future().then(|r| match r {","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:3028"}},{"Del":{"text":" Ok((event, client)) => match event {","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:3085"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":69,"ins":{"up_context":[{"change":2,"pos":3180}],"down_context":[{"change":2,"pos":3256}],"flag":"","start":1052,"end":1133,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":2,"pos":3180},"to":{"change":2,"start":3180,"end":3256},"introduced_by":2}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":" future::ok(future::Loop::Break(MaybeXmppConnection {","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:1132"}}],"del_contents":[{"Del":{"text":" future::ok(future::Loop::Break(XmppConnection {","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:3255"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":71,"ins":{"up_context":[{"change":2,"pos":3297}],"down_context":[{"change":2,"pos":3344}],"flag":"","start":1134,"end":1195,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":2,"pos":3297},"to":{"change":2,"start":3297,"end":3344},"introduced_by":2}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":" inner: Some((sink, stream)),","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:1194"}}],"del_contents":[{"Del":{"text":" inner: client,","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:3343"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":76,"ins":{"up_context":[{"change":2,"pos":3513}],"down_context":[{"change":2,"pos":3595}],"flag":"","start":1196,"end":1284,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":2,"pos":3513},"to":{"change":2,"start":3513,"end":3595},"introduced_by":2}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":" future::ok(future::Loop::Continue((sink, stream, account)))","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:1283"}}],"del_contents":[{"Del":{"text":" future::ok(future::Loop::Continue((client, account)))","pos":"2L3JHRULRLBHT4K2VE4MHKDFX5RJXYUDTJJCLTUYH3DOOVCJT6WAC:3594"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":93,"ins":{"up_context":[{"change":3,"pos":745}],"down_context":[{"change":3,"pos":784}],"flag":"","start":1285,"end":1428,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":745},"to":{"change":3,"start":888,"end":942},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":942},"to":{"change":3,"start":1587,"end":1649},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":" let MaybeXmppConnection { account, inner } = self;","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:1343"}},{"Add":{"text":" if let Some((sink, stream)) = inner {","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:1389"}},{"Add":{"text":" use tokio::prelude::Sink;","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:1427"}}],"del_contents":[{"Del":{"text":" let XmppConnection { account, inner } = self;","pos":"X6L47BHQPIWFWO53QU6GMRYZC7VPFR4AFTJV7MZIJWIMZG5L65WQC:941"}},{"Del":{"text":" let client = inner;","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:1614"}},{"Del":{"text":" use tokio::prelude::Sink;","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:1648"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":97,"ins":{"up_context":[{"change":3,"pos":785}],"down_context":[{"change":3,"pos":2608}],"flag":"","start":1429,"end":3348,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":785},"to":{"change":3,"start":1650,"end":3187},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":" let presence = stanzas::make_presence(&account);","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:1489"}},{"Add":{"text":" info!(\"Sending presence...\");","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:1531"}},{"Add":{"text":" Box::new(","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:1553"}},{"Add":{"text":" sink.send(presence)","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:1589"}},{"Add":{"text":" .map_err(|e| {","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:1624"}},{"Add":{"text":" error!(\"Error on send self-presence: {}\", e);","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:1694"}},{"Add":{"text":" \"Cann't send self-presence\".to_owned()","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:1757"}},{"Add":{"text":" })","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:1780"}},{"Add":{"text":" .join(","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:1807"}},{"Add":{"text":" future::loop_fn((account.clone(), stream), |(account, stream)| {","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:1896"}},{"Add":{"text":" stream","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:1931"}},{"Add":{"text":" .into_future()","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:1978"}},{"Add":{"text":" .map_err(|(e, _)| {","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:2030"}},{"Add":{"text":" error!(\"Error on reading self-presence: {}\", e);","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:2115"}},{"Add":{"text":" \"Cann't read self-presence\".to_owned()","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:2190"}},{"Add":{"text":" })","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:2225"}},{"Add":{"text":" .and_then(|(event, stream)| match event {","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:2299"}},{"Add":{"text":" Some(event) => {","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:2352"}},{"Add":{"text":" if let tokio_xmpp::Event::Stanza(e) = event {","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:2438"}},{"Add":{"text":" info!(\"Get stanza: {:?}\", e);","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:2512"}},{"Add":{"text":" if e.name() == \"presence\"","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:2582"}},{"Add":{"text":" && e.attr(\"from\")","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:2648"}},{"Add":{"text":" .map_or(false, |f| f == account.jid)","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:2737"}},{"Add":{"text":" && e.attr(\"to\").map_or(false, |f| f == account.jid)","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:2837"}},{"Add":{"text":" {","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:2883"}},{"Add":{"text":" info!(\"Self presence\");","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:2955"}},{"Add":{"text":" future::ok(future::Loop::Break(stream))","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:3043"}},{"Add":{"text":" } else {","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:3096"}},{"Add":{"text":" future::ok(future::Loop::Continue((","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:3180"}},{"Add":{"text":" account, stream,","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:3249"}},{"Add":{"text":" )))","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:3301"}},{"Add":{"text":" }","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:3347"}}],"del_contents":[{"Del":{"text":" let presence = stanzas::make_presence(&account);","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:1706"}},{"Del":{"text":" info!(\"Sending presence...\");","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:1744"}},{"Del":{"text":" let account2 = account.clone();","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:1784"}},{"Del":{"text":" Box::new(","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:1802"}},{"Del":{"text":" client","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:1821"}},{"Del":{"text":" .send(presence)","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:1853"}},{"Del":{"text":" .map_err(|e| {","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:1884"}},{"Del":{"text":" error!(\"Error on send self-presence: {}\", e);","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:1950"}},{"Del":{"text":" \"Cann't send self-presence\".to_owned()","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:2009"}},{"Del":{"text":" })","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:2028"}},{"Del":{"text":" .and_then(move |client| {","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:2070"}},{"Del":{"text":" future::loop_fn((account2.clone(), client), |(account, client)| {","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:2156"}},{"Del":{"text":" client","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:2187"}},{"Del":{"text":" .into_future()","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:2230"}},{"Del":{"text":" .map_err(|(e, _)| {","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:2278"}},{"Del":{"text":" error!(\"Error on reading self-presence: {}\", e);","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:2359"}},{"Del":{"text":" \"Cann't read self-presence\".to_owned()","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:2430"}},{"Del":{"text":" })","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:2461"}},{"Del":{"text":" .and_then(|(event, client)| match event {","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:2531"}},{"Del":{"text":" Some(event) => {","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:2580"}},{"Del":{"text":" if let tokio_xmpp::Event::Stanza(e) = event {","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:2662"}},{"Del":{"text":" info!(\"Get stanza: {:?}\", e);","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:2732"}},{"Del":{"text":" if e.name() == \"presence\"","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:2798"}},{"Del":{"text":" && e.attr(\"from\").map_or(false, |f| f == account.jid)","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:2896"}},{"Del":{"text":" && e.attr(\"to\").map_or(false, |f| f == account.jid)","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:2992"}},{"Del":{"text":" {","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:3034"}},{"Del":{"text":" info!(\"Self presence\");","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:3102"}},{"Del":{"text":" future::ok(future::Loop::Break(client))","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:3186"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":130,"ins":{"up_context":[{"change":3,"pos":2657}],"down_context":[{"change":3,"pos":2743}],"flag":"","start":3349,"end":3435,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":2657},"to":{"change":3,"start":3188,"end":3286},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":" future::err(\"Got wrong event\".to_owned())","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:3434"}}],"del_contents":[{"Del":{"text":" future::ok(future::Loop::Continue((account, client)))","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:3285"}}]}},{"Edit":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":132,"atom":{"EdgeMap":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":2785},"to":{"change":3,"start":3287,"end":3414},"introduced_by":3}],"inode":{"change":3,"pos":17}}},"contents":[{"Del":{"text":" } else {","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:3331"}},{"Del":{"text":" future::err(\"Got wrong event\".to_owned())","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:3413"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":133,"ins":{"up_context":[{"change":3,"pos":2823}],"down_context":[{"change":3,"pos":3783}],"flag":"","start":3436,"end":4300,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":2823},"to":{"change":3,"start":3415,"end":3996},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":" None => future::err(\"Got closed stream\".to_owned()),","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:3524"}},{"Add":{"text":" })","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:3559"}},{"Add":{"text":" })","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:3586"}},{"Add":{"text":" .map_err(|e| format!(\"waiting self-presence: {}\", e)),","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:3665"}},{"Add":{"text":" )","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:3687"}},{"Add":{"text":" .then(|r| match r {","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:3727"}},{"Add":{"text":" Err(e) => {","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:3763"}},{"Add":{"text":" error!(\"Self-presence waiting error: {}\", e);","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:3837"}},{"Add":{"text":" future::err(account)","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:3886"}},{"Add":{"text":" }","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:3912"}},{"Add":{"text":" Ok(inner) => future::ok(MaybeXmppConnection {","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:3982"}},{"Add":{"text":" account,","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:4019"}},{"Add":{"text":" inner: Some(inner),","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:4067"}},{"Add":{"text":" }),","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:4095"}},{"Add":{"text":" }),","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:4119"}},{"Add":{"text":" )","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:4133"}},{"Add":{"text":" } else {","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:4150"}},{"Add":{"text":" warn!(\"Don't gen connection on self-presence\");","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:4210"}},{"Add":{"text":" Box::new(future::err(account)) as Box>","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:4289"}},{"Add":{"text":" }","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:4299"}}],"del_contents":[{"Del":{"text":" }","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:3448"}},{"Del":{"text":" None => future::err(\"Got closed stream\".to_owned()),","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:3533"}},{"Del":{"text":" })","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:3564"}},{"Del":{"text":" })","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:3587"}},{"Del":{"text":" .map_err(|e| format!(\"waiting self-presence: {}\", e))","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:3661"}},{"Del":{"text":" })","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:3680"}},{"Del":{"text":" .then(|r| match r {","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:3716"}},{"Del":{"text":" Err(e) => {","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:3748"}},{"Del":{"text":" error!(\"Self-presence waiting error: {}\", e);","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:3818"}},{"Del":{"text":" future::err(account)","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:3863"}},{"Del":{"text":" }","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:3885"}},{"Del":{"text":" Ok(inner) => future::ok(XmppConnection { account, inner }),","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:3965"}},{"Del":{"text":" }),","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:3985"}},{"Del":{"text":" )","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:3995"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":181,"ins":{"up_context":[{"change":3,"pos":4311}],"down_context":[{"change":3,"pos":465}],"flag":"","start":4301,"end":4398,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":4311},"to":{"change":3,"start":4311,"end":4355},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":4311},"to":{"change":3,"start":4311,"end":4355},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":4311},"to":{"change":3,"start":4311,"end":4355},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":4311},"to":{"change":3,"start":4311,"end":4355},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":" F: future::Future + Clone + 'static,","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:4341"}},{"Add":{"text":" ::Error: std::fmt::Display,","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:4397"}}],"del_contents":[{"Del":{"text":" F: future::Future + 'static,","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:4354"}}]}},{"Edit":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":185,"atom":{"EdgeMap":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":4357},"to":{"change":3,"start":519,"end":594},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":136},"to":{"change":3,"start":4480,"end":4481},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":557},"to":{"change":3,"start":4480,"end":4481},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":594},"to":{"change":3,"start":4480,"end":4481},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":4480},"to":{"change":3,"start":4480,"end":4481},"introduced_by":3}],"inode":{"change":3,"pos":17}}},"contents":[{"Del":{"text":" let signal = signal.map_err(|_| format_err!(\"Wrong shutdown signal\"));","pos":"QWE26TMV6A5VUQLWG5ZMKHMH4NFZIQMVVXQJMPP42JUMM66C3VOQC:593"}},{"Del":{"text":"","pos":"VS6AHRWIPIMQNQAFX7INQGSUB72OW2K6HM6NGOV76RBRF6COQFRQC:4480"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":209,"ins":{"up_context":[{"change":3,"pos":5285}],"down_context":[{"change":3,"pos":5372}],"flag":"","start":4399,"end":4486,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":5285},"to":{"change":3,"start":4189,"end":4283},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":" Box::new(b.map(|b| future::Loop::Break((Some((b.0).1), b.1))))","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:4485"}}],"del_contents":[{"Del":{"text":" Box::new(b.map(|b| future::Loop::Break((Some((b.0).1), b.1.into()))))","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:4282"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":218,"ins":{"up_context":[{"change":3,"pos":5743}],"down_context":[{"change":3,"pos":5776}],"flag":"","start":4487,"end":4520,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":5743},"to":{"change":3,"start":4284,"end":4324},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":" x.1,","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:4519"}}],"del_contents":[{"Del":{"text":" x.1.into(),","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:4323"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/xmpp/mod.rs","line":224,"ins":{"up_context":[{"change":3,"pos":6018}],"down_context":[{"change":3,"pos":6105}],"flag":"","start":4521,"end":4608,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":6018},"to":{"change":3,"start":4325,"end":4419},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":" Box::new(b.map(|b| future::Loop::Break((Some((b.0).1), b.1))))","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:4607"}}],"del_contents":[{"Del":{"text":" Box::new(b.map(|b| future::Loop::Break((Some((b.0).1), b.1.into()))))","pos":"OGMBXBKPWAX4A4CY2LJITNKUYHWBFE4EVBHI4NRZO5VNZ5KXM2VQC:4418"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/main.rs","line":63,"ins":{"up_context":[{"change":3,"pos":4954}],"down_context":[{"change":3,"pos":5020}],"flag":"","start":4609,"end":4716,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":4954},"to":{"change":3,"start":4954,"end":5020},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":" .map_err(|e| {","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:4631"}},{"Add":{"text":" error!(\"Cann't get CTRL+C signal: {}\", e.0);","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:4688"}},{"Add":{"text":" e.0","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:4704"}},{"Add":{"text":" })","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:4715"}}],"del_contents":[{"Del":{"text":" .map_err(|e| error!(\"Cann't get CTRL+C signal: {}\", e.0))","pos":"X6L47BHQPIWFWO53QU6GMRYZC7VPFR4AFTJV7MZIJWIMZG5L65WQC:5019"}}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/main.rs","line":100,"ins":{"up_context":[{"change":3,"pos":6389}],"down_context":[{"change":3,"pos":6536}],"flag":"","start":4717,"end":4805,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":6389},"to":{"change":3,"start":6389,"end":6536},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":6389},"to":{"change":3,"start":6389,"end":6536},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":6389},"to":{"change":3,"start":6389,"end":6536},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":6389},"to":{"change":3,"start":6389,"end":6536},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":6389},"to":{"change":3,"start":6389,"end":6536},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":{"text":" let result = ctrt.block_on(xmpp_process(ctrl_c.clone(), recv, config.account));","pos":"AGIW6YR3J5M3PIUP3UKFMBQT2VAK6CHDDSIMK4A3KJEXH5SKQEQAC:4804"}}],"del_contents":[{"Del":{"text":" let result = ctrt.block_on(xmpp_process(","pos":"X6L47BHQPIWFWO53QU6GMRYZC7VPFR4AFTJV7MZIJWIMZG5L65WQC:6437"}},{"Del":{"text":" ctrl_c.clone().map(|_| ()),","pos":"X6L47BHQPIWFWO53QU6GMRYZC7VPFR4AFTJV7MZIJWIMZG5L65WQC:6477"}},{"Del":{"text":" recv,","pos":"X6L47BHQPIWFWO53QU6GMRYZC7VPFR4AFTJV7MZIJWIMZG5L65WQC:6495"}},{"Del":{"text":" config.account,","pos":"X6L47BHQPIWFWO53QU6GMRYZC7VPFR4AFTJV7MZIJWIMZG5L65WQC:6523"}},{"Del":{"text":" ));","pos":"X6L47BHQPIWFWO53QU6GMRYZC7VPFR4AFTJV7MZIJWIMZG5L65WQC:6535"}}]}}],"owner":"O01eg","repo":"sendxmppd-rs","token":"ZCNnd/BQ1e46gdf9flNK/lFdC+M3kv6B2Uokm9UI1uQ=","login":null}

…

Dependencies

Change contents

Review