fix startup fail example

actix-server/examples/startup-fail.rs

@@ -2,7 +2,7 @@ use std::io;
 
 use actix_rt::net::TcpStream;
 use actix_server::Server;
-use actix_service::fn_service;
+use actix_service::{fn_factory, fn_service};
 use log::info;
 
 #[actix_rt::main]
@@ -17,7 +17,15 @@ async fn main() -> io::Result<()> {
         .bind(
             "startup-fail",
             addr,
-            fn_service(move |mut _stream: TcpStream| async move { Ok::<u32, u32>(42) }),
+            fn_factory(|| async move {
+                if 1 > 2 {
+                    Ok(fn_service(move |mut _stream: TcpStream| async move {
+                        Ok::<u32, u32>(0)
+                    }))
+                } else {
+                    Err(42)
+                }
+            }),
         )?
         .workers(2)
         .run()

actix-server/examples/tcp-echo.rs

@@ -87,7 +87,7 @@ async fn main() -> io::Result<()> {
 
             svc2
         })?
-        .workers(1)
+        .workers(2)
         .run()
         .await
 }

actix-service/src/ext.rs

@@ -1,4 +1,10 @@
-use crate::{IntoService, IntoServiceFactory, Service, ServiceFactory, Transform, and_then::{AndThenSendServiceFactory, AndThenService, AndThenServiceFactory}, map::Map, map_err::MapErr, transform_err::TransformMapInitErr};
+use crate::{
+    and_then::{AndThenSendServiceFactory, AndThenService, AndThenServiceFactory},
+    map::Map,
+    map_err::MapErr,
+    transform_err::TransformMapInitErr,
+    IntoService, IntoServiceFactory, Service, ServiceFactory, Transform,
+};
 
 /// An extension trait for [`Service`]s that provides a variety of convenient adapters.
 pub trait ServiceExt<Req>: Service<Req> {

actix-service/src/pipeline.rs

@@ -175,13 +175,13 @@ where
         factory: I,
     ) -> PipelineFactory<
         impl ServiceFactory<
-            Req,
+                Req,
-            Response = SF1::Response,
+                Response = SF1::Response,
-            Error = SF::Error,
+                Error = SF::Error,
-            Config = SF::Config,
+                Config = SF::Config,
-            InitError = SF::InitError,
+                InitError = SF::InitError,
                 Service = impl Service<Req, Response = SF1::Response, Error = SF::Error> + Clone,
-        > + Clone,
+            > + Clone,
         Req,
     >
     where