- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for ResponseProducer (0.26 sec)
-
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/ResponseProducer.java
* limitations under the License. */ package org.gradle.test.fixtures.server.http; import com.sun.net.httpserver.HttpExchange; import java.io.IOException; interface ResponseProducer { default boolean isFailure() { return false; } /** * Called to handle a request. Is *not* called under lock. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 1.1K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/ChainingHttpHandler.java
try { ResponseProducer responseProducer = selectProducer(id, httpExchange); System.out.printf("[%d] sending response for %s%n", id, outcome.getDisplayName()); if (!responseProducer.isFailure()) { responseProducer.writeTo(id, httpExchange); } else { Throwable failure = responseProducer.getFailure();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 10.5K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/ExpectMethod.java
private final Duration timeout; private final Lock lock; private ResponseProducer producer = new ResponseProducer() { @Override public void writeTo(int requestId, HttpExchange exchange) throws IOException { responseBody.writeTo(requestId, exchange); } }; private ResponseProducer responseBody = new SendFixedContent(200, "hi"); private BlockingRequest blockingRequest;
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
} finally { lock.unlock(); } } @Nullable @Override public ResponseProducer selectResponseProducer(int id, HttpExchange exchange) { lock.lock(); try { if (current != null) { ResponseProducer producer = current.selectResponseProducer(id, exchange); if (producer != null) { return producer;
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/ExpectationState.java
return failure != FailureType.None; } /** * Signals that an unexpected request was received. * * @return A response to return to the client */ public ResponseProducer unexpectedRequest(String requestMethod, String path, String context) { if (failure == FailureType.None) { failure = FailureType.UnexpectedRequest; unexpectedMethod = requestMethod;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 4.8K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/Failure.java
* See the License for the specific language governing permissions and * limitations under the License. */ package org.gradle.test.fixtures.server.http; interface Failure extends ResponseProducer {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 711 bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/ExpectMaxNConcurrentRequests.java
String path = exchange.getRequestURI().getPath().substring(1); ResourceHandlerWrapper handler = selectPending(notReceived, path); return handler != null; } @Override public ResponseProducer selectResponseProducer(int id, HttpExchange exchange) { ResourceHandlerWrapper handler; lock.lock(); try { if (notReceived.isEmpty()) {
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/ResourceHandler.java
* See the License for the specific language governing permissions and * limitations under the License. */ package org.gradle.test.fixtures.server.http; interface ResourceHandler extends ResponseProducer { /** * Returns the method for this handler. */ String getMethod(); /** * Returns the path for this handler. */ String getPath();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 884 bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/TrackingHttpHandler.java
* * @return null when this handler is not expecting any further requests. */ @Nullable ResponseProducer selectResponseProducer(int id, HttpExchange exchange); boolean expecting(HttpExchange exchange); /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 1.9K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/AbstractFailure.java
* limitations under the License. */ package org.gradle.test.fixtures.server.http; import com.sun.net.httpserver.HttpExchange; abstract class AbstractFailure implements ResponseProducer, Failure { private final RuntimeException failure; public AbstractFailure(RuntimeException failure) { this.failure = failure; } @Override public boolean isFailure() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 1.5K bytes - Viewed (0)