Remove unused imports
This commit is contained in:
parent
f43c9697ae
commit
56326618a4
|
@ -1,5 +1,3 @@
|
||||||
use std::time;
|
|
||||||
|
|
||||||
use serde::{Serialize, de::DeserializeOwned};
|
use serde::{Serialize, de::DeserializeOwned};
|
||||||
|
|
||||||
use connection::Manager as ConnectionManager;
|
use connection::Manager as ConnectionManager;
|
||||||
|
|
|
@ -177,9 +177,9 @@ impl Manager {
|
||||||
if STARTED.load(Ordering::SeqCst) && CONNECTED.load(Ordering::SeqCst) && HANDSHAKED.load(Ordering::SeqCst) {
|
if STARTED.load(Ordering::SeqCst) && CONNECTED.load(Ordering::SeqCst) && HANDSHAKED.load(Ordering::SeqCst) {
|
||||||
match Self::send_and_receive(&connection, &queue) {
|
match Self::send_and_receive(&connection, &queue) {
|
||||||
Err(Error::IoError(ref err)) if err.kind() == ErrorKind::WouldBlock => (),
|
Err(Error::IoError(ref err)) if err.kind() == ErrorKind::WouldBlock => (),
|
||||||
Err(Error::IoError(err)) => {
|
Err(Error::IoError(_err)) => {
|
||||||
Self::disconnect(connection.clone());
|
Self::disconnect(connection.clone());
|
||||||
// error!("Disconnected: {}", err);
|
// error!("Disconnected: {}", _err);
|
||||||
},
|
},
|
||||||
Err(why) => error!("{}", why),
|
Err(why) => error!("{}", why),
|
||||||
Ok(_) => ()
|
Ok(_) => ()
|
||||||
|
|
Loading…
Reference in New Issue