- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 218 for ShutDown (0.08 sec)
-
mockwebserver-deprecated/api/mockwebserver.api
public fun <init> ()V public abstract fun dispatch (Lokhttp3/mockwebserver/RecordedRequest;)Lokhttp3/mockwebserver/MockResponse; public fun peek ()Lokhttp3/mockwebserver/MockResponse; public fun shutdown ()V } public final class okhttp3/mockwebserver/MockResponse : java/lang/Cloneable { public static final field Companion Lokhttp3/mockwebserver/MockResponse$Companion;
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Jul 22 12:28:51 UTC 2023 - 10.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/DispatcherTest.kt
proceed.countDown() t1.join() assertThat(idle.get()).isTrue() } @Test fun executionRejectedImmediately() { val request = newRequest("http://a/1") executor.shutdown() client.newCall(request).enqueue(callback) callback.await(request.url).assertFailure(InterruptedIOException::class.java) assertThat(listener.recordedEventTypes())
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Fri Apr 05 03:30:42 UTC 2024 - 12.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/RouteFailureTest.kt
.assertSuccessful() .assertCode(200) println("server1.requestCount ${server1.requestCount}") assertThat(server1.requestCount).isEqualTo(1) // Shutdown the proxy server if (cleanShutdown) { server1.shutdown() } // Now redirect with DNS to proxyServer2 // Then redirect socket connection to server2 dns["myproxy"] = listOf(proxyServer2)
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Tue May 14 17:48:07 UTC 2024 - 11.9K bytes - Viewed (0) -
docs/em/docs/advanced/testing-events.md
# ๐ฌ ๐: ๐ด - ๐คซ ๐โ ๐ ๐ช ๐ ๐ ๐โ๐ฆบ (`startup` & `shutdown`) ๐ ๐ ๐ฏ, ๐ ๐ช โ๏ธ `TestClient` โฎ๏ธ `with` ๐: ```Python hl_lines="9-12 20-24" {!../../docs_src/app_testing/tutorial003.py!}
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 06 20:36:54 UTC 2024 - 245 bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Apr 29 00:33:04 UTC 2024 - 10.6K bytes - Viewed (0) -
src/packaging/common/systemd/fess.service
# Set to "infinity" if you use the 'bootstrap.mlockall: true' option # in fess.yml and 'MAX_LOCKED_MEMORY=unlimited' in ${packaging.env.file} #LimitMEMLOCK=infinity # Shutdown delay in seconds, before process is tried to be killed with KILL (if configured) TimeoutStopSec=20 [Install] WantedBy=multi-user.target
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Sun Jan 15 06:32:15 UTC 2023 - 1.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerTest.kt
redQueue.shutdown() redQueue.execute("task", 100.ยตs) { // Do nothing. } taskFaker.assertNoMoreTasks() assertThat(testLogHandler.takeAll()).containsExactly( "FINE: Q10000 schedule canceled (queue is shutdown): task", ) } @Test fun scheduleThrowsWhenShutdown() { redQueue.shutdown()
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Apr 29 00:33:04 UTC 2024 - 23K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
assertTrue(future.isDone()); assertTrue(successLatch.await(200, MILLISECONDS)); assertTrue(listenerLatch.await(200, MILLISECONDS)); latch.countDown(); exec.shutdown(); exec.awaitTermination(100, MILLISECONDS); } /** * Tests that all listeners complete, even if they were added before or after the future was
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Sep 06 18:30:30 UTC 2023 - 6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractService.java
*/ @ForOverride protected abstract void doStart(); /** * This method should be used to initiate service shutdown. The invocation of this method should * cause a call to {@link #notifyStopped()}, either during this method's run, or after it has * returned. If shutdown fails, the invocation should cause a call to {@link * #notifyFailed(Throwable)} instead. *
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri May 12 18:32:03 UTC 2023 - 20.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
ignoreIoExceptions { socket.close() } // Release the threads. writerQueue.shutdown() pushQueue.shutdown() settingsListenerQueue.shutdown() } private fun failConnection(e: IOException?) { close(ErrorCode.PROTOCOL_ERROR, ErrorCode.PROTOCOL_ERROR, e) } /**
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 32.6K bytes - Viewed (0)