- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for assertCanWait (0.16 sec)
-
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/ResourceHandlerWrapper.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 2.7K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/WaitPrecondition.java
/** * Some action that must be met before it is legal to wait for an incoming request. */ interface WaitPrecondition { /** * Must be called under lock. */ void assertCanWait() throws IllegalStateException;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 892 bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/ExpectMaxNConcurrentRequests.java
} @Override public WaitPrecondition getWaitPrecondition() { return this; } @Override public void assertCanWait() throws IllegalStateException { lock.lock(); try { previous.assertCanWait(); if (notReceived.isEmpty()) { // Have received all requests so downstream can wait. return; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 14.4K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/ExpectMethod.java
} SendPartialResponseThenBlock block = new SendPartialResponseThenBlock(lock, timeout, new WaitPrecondition() { @Override public void assertCanWait() throws IllegalStateException { ExpectMethod.this.precondition.assertCanWait(); } }, content); replaceBody(block, block); return this; } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 6.6K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/ExpectInAnyOrder.java
} } @Override public WaitPrecondition getWaitPrecondition() { return () -> { for (TrackingHttpHandler handler : expected) { handler.getWaitPrecondition().assertCanWait(); } }; } @Override public void cancelBlockedRequests() { lock.lock(); try { if (current != null) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 3.4K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/SendPartialResponseThenBlock.java
} exchange.getResponseBody().write(content, 1024, content.length - 1024); } @Override public void waitUntilBlocked() { lock.lock(); try { precondition.assertCanWait(); if (released) { throw new IllegalStateException("Response has already been released."); } long now = clock.getCurrentTime();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 4.7K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/BlockingHttpServer.java
httpExchange.sendResponseHeaders(200, 0); } } private class MustBeRunning implements WaitPrecondition { @Override public void assertCanWait() throws IllegalStateException { lock.lock(); try { if (!running) { throw new IllegalStateException("Cannot wait as the server is not running.");
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 21.7K bytes - Viewed (0)