- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 395 for requester (0.04 sec)
-
internal/grid/handlers.go
r := RemoteErr(err.Error()) return nil, &r } return payload, nil }, subroute...) } // Requester is able to send requests to a remote. type Requester interface { Request(ctx context.Context, h HandlerID, req []byte) ([]byte, error) } // Call the remote with the request and return the response. // The response should be returned with PutResponse when no error.
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Feb 18 16:25:55 UTC 2025 - 27.7K bytes - Viewed (0) -
internal/grid/muxclient.go
m.singleResp = false m.RecvSeq = m.SendSeq // Sync if cap(requests) > 0 { m.outBlock = make(chan struct{}, cap(requests)) } msg := message{ Op: OpConnectMux, Handler: h, Payload: payload, DeadlineMS: uint32(m.deadline.Milliseconds()), } msg.setZeroPayloadFlag() if requests == nil { msg.Flags |= FlagEOF } if m.subroute != nil {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 15.9K bytes - Viewed (0) -
api/maven-api-core/src/test/java/org/apache/maven/api/services/RequestImplementationTest.java
DependencyResolverRequest request3 = builder.session(session) .requestType(DependencyResolverRequest.RequestType.RESOLVE) .pathScope(PathScope.MAIN_COMPILE) .build(); assertEquals(request1, request2); assertEquals(request1.hashCode(), request2.hashCode()); assertNotEquals(request1, request3); String toString = request1.toString();
Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Wed Sep 17 10:01:14 UTC 2025 - 4.8K bytes - Viewed (0) -
docs/en/docs/img/sponsors/requestly.png
requestly.png...
Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Sun Oct 19 19:12:22 UTC 2025 - 17.9K bytes - Viewed (0) -
mockwebserver/README.md
// Optional: confirm that your app made the HTTP requests you were expecting. RecordedRequest request1 = server.takeRequest(); assertEquals("/v1/chat/messages/", request1.getUrl().encodedPath()); assertNotNull(request1.getHeaders().get("Authorization")); RecordedRequest request2 = server.takeRequest(); assertEquals("/v1/chat/messages/2", request2.getUrl().encodedPath()); RecordedRequest request3 = server.takeRequest();
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Thu Oct 30 21:39:59 UTC 2025 - 8.1K bytes - Viewed (0) -
api/maven-api-core/src/main/java/org/apache/maven/api/services/Request.java
* Implementations must ensure that if two requests are equal according to * {@link #equals(Object)}, they have the same hashcode. * * @return a hash code value for this request */ @Override int hashCode(); /** * Returns {@code true} if the specified object is equal to this request.Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Fri Feb 07 00:45:02 UTC 2025 - 4K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Request.kt
this.method = "GET" this.headers = Headers.Builder() } internal constructor(request: Request) { this.url = request.url this.method = request.method this.body = request.body this.tags = request.tags this.headers = request.headers.newBuilder() this.cacheUrlOverride = request.cacheUrlOverride } open fun url(url: HttpUrl): Builder = apply {
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Thu Oct 30 13:46:58 UTC 2025 - 14.7K bytes - Viewed (1) -
internal/handlers/forwarder.go
if f.Logger != nil && err != context.Canceled { f.Logger(err) } w.WriteHeader(http.StatusBadGateway) } func (f *Forwarder) getURLFromRequest(req *http.Request) *url.URL { // If the Request was created by Go via a real HTTP request, RequestURI will // contain the original query string. If the Request was created in code, RequestURI
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Feb 18 16:25:55 UTC 2025 - 5.7K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/DispatcherTest.kt
@Test fun executionRejectedAfterMaxRequestsChange() { val request1 = newRequest("http://a/1") val request2 = newRequest("http://a/2") dispatcher.maxRequests = 1 client.newCall(request1).enqueue(callback) executor.shutdown() client.newCall(request2).enqueue(callback) dispatcher.maxRequests = 2 // Trigger promotion. callback.await(request2.url).assertFailure(InterruptedIOException::class.java)
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Tue Nov 04 19:13:52 UTC 2025 - 15.8K bytes - Viewed (0) -
docs/es/docs/advanced/using-request-directly.md
/// ## Documentación de `Request` { #request-documentation } Puedes leer más detalles sobre el <a href="https://www.starlette.dev/requests/" class="external-link" target="_blank">objeto `Request` en el sitio de documentación oficial de Starlette</a>. /// note | Detalles Técnicos Podrías también usar `from starlette.requests import Request`.Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Wed Dec 17 20:41:43 UTC 2025 - 2.5K bytes - Viewed (0)