- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for ResourceExpectation (0.26 sec)
-
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/ResourceExpectation.java
* See the License for the specific language governing permissions and * limitations under the License. */ package org.gradle.test.fixtures.server.http; interface ResourceExpectation { ResourceHandler create(WaitPrecondition precondition);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 757 bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/BlockingHttpServer.java
List<ResourceExpectation> expectations = new ArrayList<>(); for (ExpectedRequest call : expectedCalls) { expectations.add((ResourceExpectation) call); } addNonBlockingHandler(expectations); } private void addNonBlockingHandler(final Collection<? extends ResourceExpectation> expectations) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 21.7K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/ExpectMaxNRequestsThenReleaseOne.java
public ExpectMaxNRequestsThenReleaseOne(Lock lock, int testId, Duration timeout, int maxConcurrent, WaitPrecondition previous, Collection<? extends ResourceExpectation> expectedRequests, Executor executor) { super(lock, testId, timeout, maxConcurrent, previous, expectedRequests, executor); } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 1.5K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/ExpectMethodAndRunAction.java
package org.gradle.test.fixtures.server.http; import com.sun.net.httpserver.HttpExchange; import org.gradle.api.Action; class ExpectMethodAndRunAction implements ResourceHandler, BlockingHttpServer.ExpectedRequest, ResourceExpectation { private final String method; private final String path; private final Action<? super HttpExchange> action; ExpectMethodAndRunAction(String method, String path, Action<? super HttpExchange> action) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 1.5K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/ExpectAllRequestsThenReleaseAll.java
class ExpectAllRequestsThenReleaseAll extends ExpectMaxNConcurrentRequestsThenRelease { ExpectAllRequestsThenReleaseAll(Lock lock, int testId, Duration timeout, WaitPrecondition previous, Collection<? extends ResourceExpectation> expectations, Executor executor) { super(lock, testId, timeout, expectations.size(), previous, expectations, executor); } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 1.3K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/MaybeNConcurrentRequests.java
*/ class MaybeNConcurrentRequests extends ExpectMaxNConcurrentRequests { MaybeNConcurrentRequests(Lock lock, int testId, Duration timeout, int maxConcurrent, WaitPrecondition previous, Collection<? extends ResourceExpectation> expectedRequests) { super(lock, testId, timeout, maxConcurrent, previous, expectedRequests); } @Override public void assertComplete(Collection<Throwable> failures) throws AssertionError {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 1.4K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/ExpectMaxNConcurrentRequestsThenRelease.java
private final Executor executor; public ExpectMaxNConcurrentRequestsThenRelease(Lock lock, int testId, Duration timeout, int maxConcurrent, WaitPrecondition previous, Collection<? extends ResourceExpectation> expectedRequests, Executor executor) { super(lock, testId, timeout, maxConcurrent, previous, expectedRequests); this.executor = executor; } @Override protected boolean isAutoRelease() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 2K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/ResourceHandlerWrapper.java
private final WaitPrecondition owner; private final boolean autoRelease; private boolean started; private boolean received; ResourceHandlerWrapper(Lock lock, ResourceExpectation expectation, WaitPrecondition owner, boolean isAutoRelease) { this.lock = lock; handler = expectation.create(this); this.owner = owner; this.autoRelease = isAutoRelease; }
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/ExpectMaxNConcurrentRequests.java
private final ExpectationState state = new ExpectationState(); ExpectMaxNConcurrentRequests(Lock lock, int testId, Duration timeout, int maxConcurrent, WaitPrecondition previous, Collection<? extends ResourceExpectation> expectedRequests) { if (expectedRequests.size() < maxConcurrent) { throw new IllegalArgumentException("Too few requests specified."); } this.lock = lock;
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
import java.io.File; import java.io.IOException; import java.time.Duration; import java.util.concurrent.locks.Lock; class ExpectMethod implements ResourceHandler, BuildableExpectedRequest, ResourceExpectation, BlockingRequest { private final String method; private final String path; private final Duration timeout; private final Lock lock; private ResponseProducer producer = new ResponseProducer() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 6.6K bytes - Viewed (0)