- Sort Score
- Result 10 results
- Languages All
Results 1 - 1 of 1 for BlockingExchange (0.17 sec)
-
maven-embedder/src/main/java/org/apache/maven/cli/transfer/SimplexTransferListener.java
public void waitForProcessed() throws InterruptedException { // nothing, is async } } private static class BlockingExchange extends Exchange { private final CountDownLatch latch = new CountDownLatch(1); private BlockingExchange(TransferEvent event) { super(event); } @Override public void process(Consumer<TransferEvent> consumer) {
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Jun 11 20:50:56 UTC 2024 - 8.4K bytes - Viewed (0)