Process leftover commands

Dependencies

• [2] PHPCAQ6Z Use env logger. Implement command loop
• [3] AVBHYHOA Stop xmpp thread by shudown

Change contents

• replacement in src/xmpp.rs at line 30
  [2.771]→[2.771:816](∅→∅)
  − Ok(Either::A((_x, _b))) => {
  [2.771]

  [2.816]
  + Ok(Either::A((_x, b))) => {
• replacement in src/xmpp.rs at line 32
  [2.858]→[2.858:914](∅→∅)
  − future::ok(future::Loop::Break(()))
  [2.858]

  [2.914]
  + future::ok(future::Loop::Break(b.into_inner()))
• replacement in src/xmpp.rs at line 38
  [2.1113]→[2.1113:1158](∅→∅)
  − Err(Either::A((e, _b))) => {
  [2.1113]

  [2.1158]
  + Err(Either::A((e, b))) => {
• replacement in src/xmpp.rs at line 41
  [2.1257]→[2.1257:1313](∅→∅)
  − future::ok(future::Loop::Break(()))
  [2.1257]

  [2.1313]
  + future::ok(future::Loop::Break(b.into_inner()))
• edit in src/xmpp.rs at line 52
  [2.1634]

  [2.1634]
  + }).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",

  + )))

  + }