|
|
@ -202,7 +202,6 @@ public class QuotaCheckReactiveFilterTest {
|
|
|
|
// Unirate waiting 1000ms
|
|
|
|
// Unirate waiting 1000ms
|
|
|
|
MetadataContext.LOCAL_SERVICE = "TestApp2";
|
|
|
|
MetadataContext.LOCAL_SERVICE = "TestApp2";
|
|
|
|
long startTimestamp = System.currentTimeMillis();
|
|
|
|
long startTimestamp = System.currentTimeMillis();
|
|
|
|
quotaCheckReactiveFilter.filter(exchange, webFilterChain);
|
|
|
|
|
|
|
|
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 {
|
|
|
|