- Sort Score
- Result 10 results
- Languages All
Results 491 - 500 of 926 for Executed (0.08 sec)
-
guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/AbstractFuture.java
Listener(Runnable command, Executor executor) { this.command = checkNotNull(command); this.executor = checkNotNull(executor); } void execute() { try { executor.execute(command); } catch (RuntimeException e) { log.log( Level.SEVERE, "RuntimeException while executing runnable " + command + " with executor " + executor,
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Jan 22 19:37:41 UTC 2024 - 12.3K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/kt/CacheResponse.kt
.build() fun run() { val request = Request.Builder() .url("http://publicobject.com/helloworld.txt") .build() val response1Body = client.newCall(request).execute().use { if (!it.isSuccessful) throw IOException("Unexpected code $it") println("Response 1 response: $it") println("Response 1 cache response: ${it.cacheResponse}")
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http/CancelTest.kt
} fail("Expected connection to be closed") } }, ), ) cancelLater(call, 500) assertFailsWith<IOException> { call.execute() }.also { expected -> assertEquals(cancelMode == INTERRUPT, Thread.interrupted()) } } @ParameterizedTest @ArgumentsSource(CancelModelParamProvider::class)
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 9.9K bytes - Viewed (0) -
mockwebserver/src/test/java/mockwebserver3/MockResponseSniTest.kt
.build() server.enqueue(MockResponse()) val url = server.url("/").newBuilder().host("localhost.localdomain").build() val call = client.newCall(Request(url = url)) val response = call.execute() assertThat(response.isSuccessful).isTrue() val recordedRequest = server.takeRequest() assertThat(recordedRequest.handshakeServerNames).containsExactly(url.host) } /**
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 5.9K bytes - Viewed (0) -
docs/pt/docs/advanced/settings.md
code ->> function: say_hi(name="Rick") function ->> execute: executar código da função execute ->> code: retornar o resultado end rect rgba(0, 255, 0, .1) code ->> function: say_hi(name="Rick", salutation="Mr.") function ->> execute: executar código da função execute ->> code: retornar o resultado end rect rgba(0, 255, 255, .1)
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 06 20:36:54 UTC 2024 - 17K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/query/BooleanQueryCommand.java
@Override protected String getQueryClassName() { return BooleanQuery.class.getSimpleName(); } @Override public QueryBuilder execute(final QueryContext context, final Query query, final float boost) { if (query instanceof final BooleanQuery booleanQuery) { if (logger.isDebugEnabled()) { logger.debug("{}:{}", query, boost);
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 2.9K bytes - Viewed (0) -
internal/ioutil/ioutil.go
}, } ODirectPoolSmall = sync.Pool{ New: func() interface{} { b := disk.AlignedBlock(SmallBlock) return &b }, } ) // WriteOnCloser implements io.WriteCloser and always // executes at least one write operation if it is closed. // // This can be useful within the context of HTTP. At least // one write operation must happen to send the HTTP headers // to the peer. type WriteOnCloser struct {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jul 26 12:55:01 UTC 2024 - 10.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
ListeningExecutorService service = listeningDecorator(delegate); Runnable task = new Runnable() { @Override public void run() {} }; service.execute(task); verify(delegate).execute(task); } public void testListeningDecorator_scheduleSuccess() throws Exception { final CountDownLatch completed = new CountDownLatch(1); ScheduledThreadPoolExecutor delegate =
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 28.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http/ThreadInterruptTest.kt
fail("Expected connection to be closed") } }, ) .build(), ) interruptLater(500) assertFailsWith<IOException> { call.execute() } } @Test fun interruptReadingResponseBody() { val responseBodySize = 8 * 1024 * 1024 // 8 MiB. server.enqueue( MockResponse()
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 4.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/backup/AdminBackupAction.java
} @Override protected String getActionRole() { return ROLE; } @Execute @Secured({ ROLE, ROLE + VIEW }) public HtmlResponse index() { saveToken(); return asListHtml(); } @Execute @Secured({ ROLE }) public HtmlResponse upload(final UploadForm form) { validate(form, messages -> {}, this::asListHtml);
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Sat Oct 12 01:54:46 UTC 2024 - 28.5K bytes - Viewed (0)