Merge pull request bytebeamio#393 from bytebeamio/fix-v5

Fix v5

.github/workflows/build.yml

@@ -2,6 +2,10 @@ on:
   pull_request:
     branches:
       - master
+    paths:
+      - '**.rs'
+      - 'Cargo.*'
+      - '*/Cargo.*'
 
 name: Build and Test
 

benchmarks/clients/mesh.rs

@@ -3,7 +3,7 @@ use tokio::task;
 use std::thread;
 use std::path::PathBuf;
 use bytes::Bytes;
-use rumqttlog::router::{Data};
+use rumqttlog::router::Data;
 
 mod common;
 
@@ -74,5 +74,3 @@ async fn read(tx: Sender<(usize, RouterInMessage)>) {
 
     println!("Id = {}, Total size = {}", id, total_size);
 }
-
-

benchmarks/clients/rumqttasync.rs

@@ -1,4 +1,5 @@
-use rumqttc::*;
+use rumqttc::{AsyncClient, Event, Incoming, MqttOptions, QoS};
+
 use std::error::Error;
 use std::time::{Duration, Instant};
 

benchmarks/clients/rumqttasyncqos0.rs

@@ -1,4 +1,5 @@
-use rumqttc::*;
+use rumqttc::{AsyncClient, Event, Incoming, MqttOptions, QoS};
+
 use std::error::Error;
 use std::time::{Duration, Instant};
 

benchmarks/clients/rumqttsync.rs

@@ -1,4 +1,4 @@
-use rumqttc::{self, Client, Event, Incoming, MqttOptions, QoS};
+use rumqttc::{Client, Event, Incoming, MqttOptions, QoS};
 use std::error::Error;
 use std::thread;
 use std::time::{Duration, Instant};