cargo fmt

zenoh-bridge-mqtt/src/main.rs

@@ -12,10 +12,10 @@
 //   ZettaScale Zenoh Team, <[email protected]>
 //
 use clap::{App, Arg};
-use zenoh_plugin_trait::Plugin;
 use std::str::FromStr;
 use zenoh::config::{Config, ModeDependentValue};
 use zenoh::prelude::*;
+use zenoh_plugin_trait::Plugin;
 
 macro_rules! insert_json5 {
     ($config: expr, $args: expr, $key: expr, if $name: expr) => {
@@ -169,7 +169,10 @@ r#"-w, --generalise-pub=[String]...   'A list of key expression to use for gener
 #[async_std::main]
 async fn main() {
     env_logger::Builder::from_env(env_logger::Env::default().default_filter_or("z=info")).init();
-    log::info!("zenoh-bridge-mqtt {}", zenoh_plugin_mqtt::MqttPlugin::PLUGIN_LONG_VERSION);
+    log::info!(
+        "zenoh-bridge-mqtt {}",
+        zenoh_plugin_mqtt::MqttPlugin::PLUGIN_LONG_VERSION
+    );
 
     let config = parse_args();
     let rest_plugin = config.plugin("rest").is_some();

zenoh-plugin-mqtt/src/mqtt_helpers.rs

@@ -16,8 +16,8 @@ use ntex::util::{ByteString, Bytes};
 use ntex_mqtt::{error::SendPacketError, v3, v5};
 use std::convert::TryInto;
 use std::sync::{Arc, Mutex};
-use zenoh::Result as ZResult;
 use zenoh::prelude::*;
+use zenoh::Result as ZResult;
 use zenoh_core::zlock;
 
 use crate::config::Config;

zenoh-plugin-mqtt/src/mqtt_session_state.rs

@@ -18,9 +18,9 @@ use lazy_static::__Deref;
 use ntex::util::{ByteString, Bytes};
 use std::convert::TryInto;
 use std::{collections::HashMap, sync::Arc};
-use zenoh::Result as ZResult;
 use zenoh::prelude::r#async::*;
 use zenoh::subscriber::Subscriber;
+use zenoh::Result as ZResult;
 
 #[derive(Debug)]
 pub(crate) struct MqttSessionState<'a> {