- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 365 for responsive (0.09 sec)
-
android/guava/src/com/google/common/util/concurrent/AbstractFutureState.java
for (Waiter currentWaiter = head; currentWaiter != null; currentWaiter = currentWaiter.next) { currentWaiter.unpark(); } } // Gets and Timed Gets // // * Be responsive to interruption // * Don't create Waiter nodes if you aren't going to park, this helps reduce contention on // waitersField. // * Future completion is defined by when #valueField becomes non-null/non DelegatingToFuture
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 33.2K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractFutureState.java
for (Waiter currentWaiter = head; currentWaiter != null; currentWaiter = currentWaiter.next) { currentWaiter.unpark(); } } // Gets and Timed Gets // // * Be responsive to interruption // * Don't create Waiter nodes if you aren't going to park, this helps reduce contention on // waitersField. // * Future completion is defined by when #valueField becomes non-null/non DelegatingToFuture
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 34.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/ViewHelper.java
} }); return response; } /** * Writes no-cache headers to the response. * * @param response the stream response * @param responseData the response data */ protected void writeNoCache(final StreamResponse response, final ResponseData responseData) { response.header("Pragma", "no-cache"); response.header("Cache-Control", "no-cache");
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 52.4K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Response.kt
} internal constructor(response: Response) { this.request = response.request this.protocol = response.protocol this.code = response.code this.message = response.message this.handshake = response.handshake this.headers = response.headers.newBuilder() this.body = response.body this.socket = response.socket this.networkResponse = response.networkResponse
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon Jul 28 14:39:28 UTC 2025 - 18.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/sso/SsoAuthenticator.java
*/ void resolveCredential(LoginCredentialResolver resolver); /** * Gets the action response for the specified SSO response type. * @param responseType The type of SSO response required. * @return The action response. */ ActionResponse getResponse(SsoResponseType responseType); /** * Performs logout for the specified user.
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 2.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/dict/DictionaryManager.java
try (CurlResponse response = ComponentUtil.getCurlHelper() .get("/_configsync/file") .param("fields", "path,@timestamp") .param("size", ComponentUtil.getFessConfig().getPageDictionaryMaxFetchSize()) .execute()) { final Map<String, Object> contentMap = response.getContent(OpenSearchCurl.jsonParser());
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 7.7K bytes - Viewed (0) -
README.md
```java OkHttpClient client = new OkHttpClient(); String run(String url) throws IOException { Request request = new Request.Builder() .url(url) .build(); try (Response response = client.newCall(request).execute()) { return response.body().string(); } } ``` Post to a Server ---------------- This program posts data to a service. [Full source][post_example]. ```java
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon Jul 28 07:33:49 UTC 2025 - 8.8K bytes - Viewed (0) -
src/test/java/org/codelibs/curl/CurlResponseTest.java
assertEquals(statusCode, response.getHttpStatusCode()); } @Test public void testEncoding() { CurlResponse response = new CurlResponse(); String encoding = "UTF-8"; response.setEncoding(encoding); assertEquals(encoding, response.getEncoding()); } @Test public void testContentException() {
Registered: Thu Sep 04 15:34:10 UTC 2025 - Last Modified: Thu Jul 31 01:01:12 UTC 2025 - 11.5K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/TrailersTest.kt
call.execute().use { response -> val source = response.body.source() assertThat(response.header("h1")).isEqualTo("v1") assertThat(response.peekTrailers()).isNull() assertThat(source.readUtf8()).isEqualTo(responseBody) assertThat(response.peekTrailers()).isEqualTo(headersOf("t1", "v2")) assertThat(response.peekTrailers()).isEqualTo(headersOf("t1", "v2")) // Idempotent.
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon Jul 07 18:57:05 UTC 2025 - 18K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/EventListenerTest.kt
.build(), ) var response = call.execute() assertThat(response.code).isEqualTo(200) assertThat(response.body.string()).isEqualTo("abc") response.close() listener.clearAllEvents() call = call.clone() response = call.execute() assertThat(response.code).isEqualTo(200) assertThat(response.body.string()).isEqualTo("abc") response.close()
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Jun 20 11:46:46 UTC 2025 - 60.4K bytes - Viewed (0)