- Sort Score
- Result 10 results
- Languages All
Results 331 - 340 of 1,015 for executes (0.12 sec)
-
okhttp-android/src/test/kotlin/okhttp3/android/RobolectricOkHttpClientTest.kt
request.newBuilder() .build() val call = client.newCall(networkRequest) call.execute().use { response -> assertThat(response.code).isEqualTo(200) assertThat(response.cacheResponse).isNull() } val cachedCall = client.newCall(request) cachedCall.execute().use { response -> assertThat(response.code).isEqualTo(200) assertThat(response.cacheResponse).isNotNull()
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Wed Apr 10 19:46:48 UTC 2024 - 2.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/cache/CacheAction.java
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 3.4K bytes - Viewed (0) -
docs/bigdata/README.md
``` ./bin/spark-submit --class org.apache.spark.examples.SparkPi \ --master yarn-client \ --num-executors 1 \ --driver-memory 512m \ --executor-memory 512m \ --executor-cores 1 \ examples/jars/spark-examples*.jar 10 ``` The job should produce an output as shown below. Note the value of pi in the output. ```
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 29 04:28:45 UTC 2022 - 14.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/job/ExecJob.java
protected int timeout = -1; // sec protected boolean processTimeout = false; public abstract String execute(); protected abstract String getExecuteType(); public String execute(final JobExecutor jobExecutor) { jobExecutor(jobExecutor); return execute(); } public ExecJob jobExecutor(final JobExecutor jobExecutor) { this.jobExecutor = jobExecutor;
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Fri Oct 11 21:11:58 UTC 2024 - 7.7K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/client/FesenClient.java
public <Request extends ActionRequest, Response extends ActionResponse> ActionFuture<Response> execute( final ActionType<Response> action, final Request request) { return client.execute(action, request); } @Override public <Request extends ActionRequest, Response extends ActionResponse> void execute(final ActionType<Response> action,
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Nov 07 04:44:10 UTC 2024 - 19.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/tls/CertificatePinnerChainValidationTest.kt
.body("abc") .build(), ) val call1 = client.newCall( Request.Builder() .url(server.url("/")) .build(), ) val response1 = call1.execute() assertThat(response1.body.string()).isEqualTo("abc") } /** * The pinner should accept an intermediate from the server's chain. */ @Test fun pinIntermediatePresentInChain() {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 23.8K bytes - Viewed (0) -
okhttp-android/src/main/baseline-prof.txt
HSPLandroidx/arch/core/executor/ArchTaskExecutor;-><init>()V HSPLandroidx/arch/core/executor/ArchTaskExecutor;->getInstance()Landroidx/arch/core/executor/ArchTaskExecutor; HSPLandroidx/arch/core/executor/DefaultTaskExecutor$1;-><init>(Landroidx/arch/core/executor/DefaultTaskExecutor;)V HSPLandroidx/arch/core/executor/DefaultTaskExecutor;-><init>()V HSPLandroidx/arch/core/executor/DefaultTaskExecutor;->isMainThread()Z HSPLandroidx/arch/core/executor/TaskExecutor;-><init>()V
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Mar 21 11:22:00 UTC 2022 - 127.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/plugin/AdminPluginAction.java
} @Override protected String getActionRole() { return ROLE; } @Execute @Secured({ ROLE, ROLE + VIEW }) public HtmlResponse index() { saveToken(); return asListHtml(); } @Execute @Secured({ ROLE }) public HtmlResponse delete(final DeleteForm form) {
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 9.9K bytes - Viewed (0) -
okhttp-logging-interceptor/src/test/java/okhttp3/logging/LoggingEventListenerTest.kt
assumeNotWindows() server.enqueue( MockResponse.Builder() .body("Hello!") .setHeader("Content-Type", PLAIN) .build(), ) val response = client.newCall(request().build()).execute() assertThat(response.body).isNotNull() response.body.bytes() logRecorder .assertLogMatch(Regex("""callStart: Request\{method=GET, url=$url\}""")) .assertLogMatch(Regex("""proxySelectStart: $url"""))
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sun Jan 14 10:20:09 UTC 2024 - 10.2K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/MockFutureListener.java
* result doesn't match the expected value. */ public void assertSuccess(Object expectedData) throws Throwable { // Verify that the listener executed in a reasonable amount of time. Assert.assertTrue(countDownLatch.await(1L, SECONDS)); try { Assert.assertEquals(expectedData, future.get()); } catch (ExecutionException e) { throw e.getCause();
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri May 12 18:12:42 UTC 2023 - 3K bytes - Viewed (0)