diff --git a/src/client/http.rs b/src/client/http.rs index 892def0..27140ed 100644 --- a/src/client/http.rs +++ b/src/client/http.rs @@ -1,3 +1,5 @@ +use std::time::Duration; + use crate::server::PayloadSource; use alloy_rpc_types_engine::JwtSecret; use http::Uri; @@ -32,7 +34,10 @@ impl HttpClient { .enable_http2() .build(); - let client = Client::builder(TokioExecutor::new()).build(connector); + let client = Client::builder(TokioExecutor::new()) + .pool_timer(hyper_util::rt::TokioTimer::new()) + .pool_idle_timeout(Duration::from_millis(2_500)) + .build(connector); let client = ServiceBuilder::new() .layer(DecompressionLayer::new()) diff --git a/src/client/rpc.rs b/src/client/rpc.rs index 9cee07a..95ba958 100644 --- a/src/client/rpc.rs +++ b/src/client/rpc.rs @@ -110,6 +110,7 @@ impl RpcClient { let auth_client = HttpClientBuilder::new() .set_http_middleware(tower::ServiceBuilder::new().layer(auth_layer)) .request_timeout(Duration::from_millis(timeout)) + .set_tcp_no_delay(true) .build(auth_rpc.to_string())?; Ok(Self {