From a611a140961975a406bc18644e599626205c48c9 Mon Sep 17 00:00:00 2001
From: Alex Leong <alex@buoyant.io>
Date: Tue, 28 May 2019 13:33:42 -0700
Subject: [PATCH] Fix tower-hedge tests and add to CI (#287)

Signed-off-by: Alex Leong <alex@buoyant.io>
---
 azure-pipelines.yml        | 1 +
 tower-hedge/tests/hedge.rs | 5 +++++
 2 files changed, 6 insertions(+)

diff --git a/azure-pipelines.yml b/azure-pipelines.yml
index 37989740..1ad112cd 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 edae7cdc..a86c76ce 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");