update

.github/workflows/test.yml

@@ -20,6 +20,8 @@ jobs:
           submodules: recursive
     - name: Check format
       run: cargo fmt --all -- --check
+    - name: Check clippy
+      run: cargo clippy --all-targets --all-features -- -D warnings
     - name: Build
       run: cargo build --verbose
     - name: Run tests

src/middleware/mod.rs

@@ -30,12 +30,12 @@ impl<Request: Send + 'static, Result: 'static> Middlewares<Request, Result> {
     }
 
     pub async fn call(&self, request: Request) -> Result {
-        let mut iter = self.middlewares.iter().rev();
+        let iter = self.middlewares.iter().rev();
         let fallback = self.fallback.clone();
         let mut next: Box<dyn FnOnce(Request) -> BoxFuture<'static, Result> + Send + Sync> =
             Box::new(move |request| (fallback)(request));
 
-        while let Some(middleware) = iter.next() {
+        for middleware in iter {
             let middleware = middleware.clone();
             let next2 = next;
             next = Box::new(move |request| {

src/server.rs

@@ -101,7 +101,7 @@ pub async fn start_server(
         })
     })?;
 
-    let upstream = Arc::new(subscription::UpstreamMiddleware::new(client.clone()));
+    let upstream = Arc::new(subscription::UpstreamMiddleware::new(client));
 
     for subscription in &config.rpcs.subscriptions {
         let subscribe_name = string_to_static_str(subscription.subscribe.clone());