From 7a491030e674956e5925e1d355b568bfe58822d1 Mon Sep 17 00:00:00 2001 From: ruansheng Date: Fri, 6 Jan 2023 16:23:45 +0800 Subject: [PATCH] Fix reactive sentinel circuit breaker tests (#3054) * 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 621335499..1e18fc056 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();