Searched refs:NUM_CONCURRENT_REQUESTS (Results 1 – 1 of 1) sorted by relevance
136 private static final int NUM_CONCURRENT_REQUESTS = 100; field in ConcurrencyTest148 clientExecutor = Executors.newFixedThreadPool(NUM_CONCURRENT_REQUESTS); in setUp()175 CyclicBarrier startBarrier = new CyclicBarrier(NUM_CONCURRENT_REQUESTS); in serverStreamingTest()176 CountDownLatch responsesDoneSignal = new CountDownLatch(NUM_CONCURRENT_REQUESTS); in serverStreamingTest()178 for (int i = 0; i < NUM_CONCURRENT_REQUESTS; i++) { in serverStreamingTest()