- Sort Score
- Result 10 results
- Languages All
Results 401 - 410 of 744 for Executed (0.07 sec)
-
src/main/java/org/codelibs/fess/app/web/base/login/ActionResponseCredential.java
private final Supplier<ActionResponse> action; public ActionResponseCredential(final Supplier<ActionResponse> action) { this.action = action; } public ActionResponse execute() { return action.get(); }
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 1.1K bytes - Viewed (0) -
docs/features/https.md
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Dec 24 00:16:30 UTC 2022 - 10.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/AbstractConfigHelper.java
import org.codelibs.core.lang.ThreadUtil; public abstract class AbstractConfigHelper { protected long reloadInterval = 1000L; public void update() { CommonPoolUtil.execute(this::load); } protected void waitForNext() { if (reloadInterval > 0) { ThreadUtil.sleep(reloadInterval); } } public abstract int load();
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 1.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/job/PurgeDocJob.java
import org.opensearch.index.query.QueryBuilders; public class PurgeDocJob { private static final Logger logger = LogManager.getLogger(PurgeDocJob.class); public String execute() { final SearchEngineClient searchEngineClient = ComponentUtil.getSearchEngineClient(); final FessConfig fessConfig = ComponentUtil.getFessConfig(); final StringBuilder resultBuf = new StringBuilder();
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 1.8K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/PostFile.java
.url("https://api.github.com/markdown/raw") .post(RequestBody.create(file, MEDIA_TYPE_MARKDOWN)) .build(); try (Response response = client.newCall(request).execute()) { if (!response.isSuccessful()) throw new IOException("Unexpected code " + response); System.out.println(response.body().string()); } }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat May 25 18:02:55 UTC 2019 - 1.5K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/kt/DevServer.kt
.sslSocketFactory(clientCertificates.sslSocketFactory(), clientCertificates.trustManager) .build() fun run() { try { val request = Request(server.url("/")) client.newCall(request).execute().use { response -> if (!response.isSuccessful) throw IOException("Unexpected code $response") println(response.request.url) } } finally { server.shutdown() } } }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 1.9K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/kt/ParseResponseWithMoshi.kt
fun run() { val request = Request.Builder() .url("https://api.github.com/gists/c2a7c39532239ff261be") .build() client.newCall(request).execute().use { response -> if (!response.isSuccessful) throw IOException("Unexpected code $response") val gist = gistJsonAdapter.fromJson(response.body!!.source()) for ((key, value) in gist!!.files!!) {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 1.6K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/PrintEventsNonConcurrent.java
System.out.println("REQUEST 1 (new connection)"); try (Response response = client.newCall(request).execute()) { // Consume and discard the response body. response.body().source().readByteString(); } System.out.println("REQUEST 2 (pooled connection)"); try (Response response = client.newCall(request).execute()) { // Consume and discard the response body. response.body().source().readByteString(); }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sun Feb 16 23:20:49 UTC 2020 - 5.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/LoomTest.kt
} @Test fun testRequest() { server.enqueue(MockResponse()) val request = Request(server.url("/")) client.newCall(request).execute().use { assertThat(it.code).isEqualTo(200) } } @Test fun testIfSupported() { assertThat(platform.isLoom()).isTrue() }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Futures.java
Callable<O> callable, Executor executor) { TrustedListenableFutureTask<O> task = TrustedListenableFutureTask.create(callable); executor.execute(task); return task; } /** * Executes {@code runnable} on the specified {@code executor}, returning a {@code Future} that * will complete after execution. *
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 25 13:13:32 UTC 2024 - 64.4K bytes - Viewed (0)