From 450efab50fff07ba06e16a7968ee12fdfc92c35b Mon Sep 17 00:00:00 2001 From: ruansheng Date: Fri, 6 Jan 2023 19:26:23 +0800 Subject: [PATCH] Fix reactive sentinel circuit breaker tests (#3054) (#3063) * Fix reactive sentinel circuit breaker tests --- .../ReactiveSentinelCircuitBreakerIntegrationTest.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/spring-cloud-alibaba-starters/spring-cloud-circuitbreaker-sentinel/src/test/java/com/alibaba/cloud/circuitbreaker/sentinel/ReactiveSentinelCircuitBreakerIntegrationTest.java b/spring-cloud-alibaba-starters/spring-cloud-circuitbreaker-sentinel/src/test/java/com/alibaba/cloud/circuitbreaker/sentinel/ReactiveSentinelCircuitBreakerIntegrationTest.java index eef6248d6..7f0b725aa 100644 --- a/spring-cloud-alibaba-starters/spring-cloud-circuitbreaker-sentinel/src/test/java/com/alibaba/cloud/circuitbreaker/sentinel/ReactiveSentinelCircuitBreakerIntegrationTest.java +++ b/spring-cloud-alibaba-starters/spring-cloud-circuitbreaker-sentinel/src/test/java/com/alibaba/cloud/circuitbreaker/sentinel/ReactiveSentinelCircuitBreakerIntegrationTest.java @@ -74,8 +74,9 @@ public class ReactiveSentinelCircuitBreakerIntegrationTest { // Then in the next 5s, the fallback method should be called. for (int i = 0; i < 5; i++) { StepVerifier.create(service.slow()).expectNext("fallback").verifyComplete(); - Thread.sleep(1000); + Thread.sleep(900); } + Thread.sleep(500); // Half-open recovery (will re-open the circuit breaker). StepVerifier.create(service.slow()).expectNext("slow").verifyComplete(); @@ -91,8 +92,9 @@ public class ReactiveSentinelCircuitBreakerIntegrationTest { for (int i = 0; i < 5; i++) { StepVerifier.create(service.slowFlux()).expectNext("flux_fallback") .verifyComplete(); - Thread.sleep(1000); + Thread.sleep(900); } + Thread.sleep(500); // Half-open recovery (will re-open the circuit breaker). StepVerifier.create(service.slowFlux()).expectNext("slowflux").verifyComplete();