perf(layer): inline layer creation for faster client build

Author: 0x676e67

src/client/layer/cookie/layer.rs

@@ -17,6 +17,7 @@ pub struct CookieServiceLayer {
 
 impl CookieServiceLayer {
     /// Create a new [`CookieServiceLayer`].
+    #[inline(always)]
     pub const fn new(cookie_store: Option<Arc<dyn CookieStore + 'static>>) -> Self {
         Self { cookie_store }
     }

src/client/layer/decoder/layer.rs

@@ -19,6 +19,7 @@ pub struct DecompressionLayer {
 
 impl DecompressionLayer {
     /// Creates a new `DecompressionLayer` with the specified `AcceptEncoding`.
+    #[inline(always)]
     pub const fn new(accept: AcceptEncoding) -> Self {
         Self { accept }
     }
@@ -27,6 +28,7 @@ impl DecompressionLayer {
 impl<S> Layer<S> for DecompressionLayer {
     type Service = Decompression<S>;
 
+    #[inline(always)]
     fn layer(&self, service: S) -> Self::Service {
         let decoder = decompression::Decompression::new(service);
         let decoder = Decompression::<S>::accept_in_place(decoder, &self.accept);

src/client/layer/redirect/mod.rs

@@ -23,6 +23,7 @@ pub struct FollowRedirectLayer<P> {
 
 impl<P> FollowRedirectLayer<P> {
     /// Create a new [`FollowRedirectLayer`] with the given redirection [`Policy`].
+    #[inline(always)]
     pub const fn with_policy(policy: P) -> Self {
         FollowRedirectLayer { policy }
     }
@@ -35,6 +36,7 @@ where
 {
     type Service = FollowRedirect<S, P>;
 
+    #[inline(always)]
     fn layer(&self, inner: S) -> Self::Service {
         FollowRedirect::with_policy(inner, self.policy.clone())
     }
@@ -52,6 +54,7 @@ where
     P: Clone,
 {
     /// Create a new [`FollowRedirect`] with the given redirection [`Policy`].
+    #[inline(always)]
     pub const fn with_policy(inner: S, policy: P) -> Self {
         FollowRedirect { inner, policy }
     }
@@ -138,22 +141,12 @@ where
         match self {
             BodyRepr::Some(_) | BodyRepr::Empty => {}
             BodyRepr::None => {
-                if let Some(body) = clone_body(policy, body) {
-                    *self = BodyRepr::Some(body);
+                if body.size_hint().exact() == Some(0) {
+                    *self = BodyRepr::Some(B::default());
+                } else if let Some(cloned) = policy.clone_body(body) {
+                    *self = BodyRepr::Some(cloned);
                 }
             }
         }
     }
 }
-
-fn clone_body<P, B, E>(policy: &P, body: &B) -> Option<B>
-where
-    P: Policy<B, E>,
-    B: Body + Default,
-{
-    if body.size_hint().exact() == Some(0) {
-        Some(B::default())
-    } else {
-        policy.clone_body(body)
-    }
-}

src/client/layer/timeout/future.rs

@@ -69,9 +69,9 @@ pin_project! {
     /// Response future for [`ResponseBodyTimeout`].
     pub struct ResponseBodyTimeoutFuture<Fut> {
         #[pin]
-        pub(crate) inner: Fut,
-        pub(crate) total_timeout: Option<Duration>,
-        pub(crate) read_timeout: Option<Duration>,
+        pub(super) inner: Fut,
+        pub(super) total_timeout: Option<Duration>,
+        pub(super) read_timeout: Option<Duration>,
     }
 }
 

src/client/layer/timeout/layer.rs

@@ -25,6 +25,7 @@ pub struct TimeoutLayer {
 
 impl TimeoutLayer {
     /// Create a new [`TimeoutLayer`].
+    #[inline(always)]
     pub const fn new(options: TimeoutOptions) -> Self {
         TimeoutLayer {
             timeout: RequestConfig::new(Some(options)),
@@ -35,6 +36,7 @@ impl TimeoutLayer {
 impl<S> Layer<S> for TimeoutLayer {
     type Service = Timeout<S>;
 
+    #[inline(always)]
     fn layer(&self, service: S) -> Self::Service {
         Timeout {
             inner: service,
@@ -64,6 +66,7 @@ where
         self.inner.poll_ready(cx)
     }
 
+    #[inline(always)]
     fn call(&mut self, req: Request<ReqBody>) -> Self::Future {
         let (total_timeout, read_timeout) = resolve_timeout_config(&self.timeout, req.extensions());
         ResponseFuture {
@@ -83,6 +86,7 @@ pub struct ResponseBodyTimeoutLayer {
 
 impl ResponseBodyTimeoutLayer {
     /// Creates a new [`ResponseBodyTimeoutLayer`].
+    #[inline(always)]
     pub const fn new(options: TimeoutOptions) -> Self {
         Self {
             timeout: RequestConfig::new(Some(options)),
@@ -93,6 +97,7 @@ impl ResponseBodyTimeoutLayer {
 impl<S> Layer<S> for ResponseBodyTimeoutLayer {
     type Service = ResponseBodyTimeout<S>;
 
+    #[inline(always)]
     fn layer(&self, inner: S) -> Self::Service {
         ResponseBodyTimeout {
             inner,
@@ -122,6 +127,7 @@ where
         self.inner.poll_ready(cx)
     }
 
+    #[inline(always)]
     fn call(&mut self, req: Request<ReqBody>) -> Self::Future {
         let (total_timeout, read_timeout) = resolve_timeout_config(&self.timeout, req.extensions());
         ResponseBodyTimeoutFuture {