fix: 将blocking call改为non-blocking call

pull/308/head
kaiy 3 years ago
parent 529b71c0e3
commit d4503e28e5

@ -203,10 +203,11 @@ public class QuotaCheckReactiveFilterTest {
MetadataContext.LOCAL_SERVICE = "TestApp2"; MetadataContext.LOCAL_SERVICE = "TestApp2";
long startTimestamp = System.currentTimeMillis(); long startTimestamp = System.currentTimeMillis();
CountDownLatch countDownLatch = new CountDownLatch(1); CountDownLatch countDownLatch = new CountDownLatch(1);
quotaCheckReactiveFilter.filter(exchange, webFilterChain).subscribe(e -> {}, t -> {}, countDownLatch::countDown); quotaCheckReactiveFilter.filter(exchange, webFilterChain).subscribe(e -> { }, t -> { }, countDownLatch::countDown);
try { try {
countDownLatch.await(); countDownLatch.await();
} catch (InterruptedException e) { }
catch (InterruptedException e) {
fail("Exception encountered.", e); fail("Exception encountered.", e);
} }
assertThat(System.currentTimeMillis() - startTimestamp).isGreaterThanOrEqualTo(1000L); assertThat(System.currentTimeMillis() - startTimestamp).isGreaterThanOrEqualTo(1000L);

Loading…
Cancel
Save