diff --git a/nmsr-aas/src/utils/http_client.rs b/nmsr-aas/src/utils/http_client.rs index e8d2644..2f9cb1d 100644 --- a/nmsr-aas/src/utils/http_client.rs +++ b/nmsr-aas/src/utils/http_client.rs @@ -71,7 +71,7 @@ pub enum NmsrHttpClient { inner: Buffer< Request, >>, + PeakEwmaDiscover>>, Request, > as Service>>::Future, >, @@ -192,7 +192,7 @@ fn create_http_client( .collect::>(); let discover = ServiceList::new(clients); - let load = PendingRequestsDiscover::new(discover, CompleteOnResponse::default()); + let load = PeakEwmaDiscover::new(discover, Duration::from_secs(1), Duration::from_millis(50), CompleteOnResponse::default()); let balanced = Balance::new(load); let balanced = ServiceBuilder::new()