diff --git a/azure-pipelines.yml b/azure-pipelines.yml index 3798974..1ad112c 100644 --- a/azure-pipelines.yml +++ b/azure-pipelines.yml @@ -17,6 +17,7 @@ jobs: - tower-buffer - tower-discover - tower-filter + - tower-hedge - tower-layer - tower-limit - tower-load-shed diff --git a/tower-hedge/tests/hedge.rs b/tower-hedge/tests/hedge.rs index edae7cd..a86c76c 100644 --- a/tower-hedge/tests/hedge.rs +++ b/tower-hedge/tests/hedge.rs @@ -21,6 +21,7 @@ fn hedge_orig_completes_first() { let (mut service, mut handle) = new_service(TestPolicy); mocked(|timer, _| { + assert!(service.poll_ready().unwrap().is_ready()); let mut fut = service.call("orig"); // Check that orig request has been issued. let (_, req) = handle.next_request().expect("orig"); @@ -46,6 +47,7 @@ fn hedge_hedge_completes_first() { let (mut service, mut handle) = new_service(TestPolicy); mocked(|timer, _| { + assert!(service.poll_ready().unwrap().is_ready()); let mut fut = service.call("orig"); // Check that orig request has been issued. let (_, _req) = handle.next_request().expect("orig"); @@ -71,6 +73,7 @@ fn completes_before_hedge() { let (mut service, mut handle) = new_service(TestPolicy); mocked(|_, _| { + assert!(service.poll_ready().unwrap().is_ready()); let mut fut = service.call("orig"); // Check that orig request has been issued. let (_, req) = handle.next_request().expect("orig"); @@ -90,6 +93,7 @@ fn request_not_retyable() { let (mut service, mut handle) = new_service(TestPolicy); mocked(|timer, _| { + assert!(service.poll_ready().unwrap().is_ready()); let mut fut = service.call(NOT_RETRYABLE); // Check that orig request has been issued. let (_, req) = handle.next_request().expect("orig"); @@ -115,6 +119,7 @@ fn request_not_clonable() { let (mut service, mut handle) = new_service(TestPolicy); mocked(|timer, _| { + assert!(service.poll_ready().unwrap().is_ready()); let mut fut = service.call(NOT_CLONABLE); // Check that orig request has been issued. let (_, req) = handle.next_request().expect("orig");