From d4503e28e5757c85246b4c94d09c5a8bc249e6ce Mon Sep 17 00:00:00 2001 From: kaiy Date: Sat, 25 Jun 2022 15:31:36 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E5=B0=86blocking=20call=E6=94=B9?= =?UTF-8?q?=E4=B8=BAnon-blocking=20call?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../ratelimit/filter/QuotaCheckReactiveFilterTest.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/spring-cloud-starter-tencent-polaris-ratelimit/src/test/java/com/tencent/cloud/polaris/ratelimit/filter/QuotaCheckReactiveFilterTest.java b/spring-cloud-starter-tencent-polaris-ratelimit/src/test/java/com/tencent/cloud/polaris/ratelimit/filter/QuotaCheckReactiveFilterTest.java index 492fb851b..6d3ef804f 100644 --- a/spring-cloud-starter-tencent-polaris-ratelimit/src/test/java/com/tencent/cloud/polaris/ratelimit/filter/QuotaCheckReactiveFilterTest.java +++ b/spring-cloud-starter-tencent-polaris-ratelimit/src/test/java/com/tencent/cloud/polaris/ratelimit/filter/QuotaCheckReactiveFilterTest.java @@ -203,10 +203,11 @@ public class QuotaCheckReactiveFilterTest { MetadataContext.LOCAL_SERVICE = "TestApp2"; long startTimestamp = System.currentTimeMillis(); CountDownLatch countDownLatch = new CountDownLatch(1); - quotaCheckReactiveFilter.filter(exchange, webFilterChain).subscribe(e -> {}, t -> {}, countDownLatch::countDown); + quotaCheckReactiveFilter.filter(exchange, webFilterChain).subscribe(e -> { }, t -> { }, countDownLatch::countDown); try { countDownLatch.await(); - } catch (InterruptedException e) { + } + catch (InterruptedException e) { fail("Exception encountered.", e); } assertThat(System.currentTimeMillis() - startTimestamp).isGreaterThanOrEqualTo(1000L);