cargo fmt

actix-server/src/accept.rs

@@ -445,7 +445,7 @@ impl Accept {
                                 delay(Instant::now() + Duration::from_millis(510)).await;
                                 let _ = r.set_readiness(mio::Ready::readable());
                             }
-                                .boxed(),
+                            .boxed(),
                         );
                         return;
                     }

actix-server/src/builder.rs

@@ -326,7 +326,7 @@ impl ServerBuilder {
             async move {
                 Worker::start(rx1, rx2, services, avail, timeout);
             }
-                .boxed(),
+            .boxed(),
         );
 
         worker
@@ -401,7 +401,7 @@ impl ServerBuilder {
                                                 .await;
                                             System::current().stop();
                                         }
-                                            .boxed(),
+                                        .boxed(),
                                     );
                                 }
                                 ready(())

actix-server/src/config.rs

@@ -139,7 +139,7 @@ impl InternalServiceFactory for ConfiguredService {
             }
             return Ok(res);
         }
-            .boxed_local()
+        .boxed_local()
     }
 }
 
@@ -266,6 +266,6 @@ where
                 }
             };
         }
-            .boxed_local()
+        .boxed_local()
     }
 }

actix-server/src/service.rs

@@ -87,7 +87,7 @@ where
                             let _ = f.await;
                             drop(guard);
                         }
-                            .boxed_local(),
+                        .boxed_local(),
                     );
                     ok(())
                 } else {

actix-server/src/ssl/openssl.rs

@@ -92,7 +92,7 @@ impl<T: AsyncRead + AsyncWrite + Unpin + 'static, P> Service for OpensslAcceptor
                 let acc = acc;
                 tokio_openssl::accept(&acc, io).await
             }
-                .boxed_local::<'static>(),
+            .boxed_local::<'static>(),
             params: Some(params),
         }
     }

actix-server/src/worker.rs

@@ -187,7 +187,7 @@ impl Worker {
                 }
                 wrk.await
             }
-                .boxed_local(),
+            .boxed_local(),
         );
     }
 

actix-utils/src/oneshot.rs

@@ -166,7 +166,7 @@ impl<T> Receiver<T> {
 
                 self.state = State::Closed(value);
             }
-            State::Closed(_) => {},
+            State::Closed(_) => {}
         };
     }
 }