∅:D[
3.6627] → [
3.6627:6644]
∅:D[
3.6627] → [
3.6627:6644]
∅:D[
3.6644] → [
2.311:425]
∅:D[
2.425] → [
3.6782:6873]
∅:D[
3.6782] → [
3.6782:6873]
∅:D[
3.6907] → [
3.6907:7379]
}).and_then(
|(opt_cmd_recv, _conn): (Option<S>, XmppConnection)| {
if let Some(cmd_recv) = opt_cmd_recv {
// process left commands
info!("Stop accepting commands");
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",
)))
}
},
)
}).and_then(|(opt_cmd_recv, _conn): (Option<S>, XmppConnection)| {
if let Some(cmd_recv) = opt_cmd_recv {
// process left commands
info!("Stop accepting commands");
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",
)))
}
})