- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 18 for Shutdown (0.23 sec)
-
mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/MockWebServerTest.kt
@Test fun shutdownWithoutStart() { val server = MockWebServer() server.shutdown() } @Test fun closeViaClosable() { val server: Closeable = MockWebServer() server.close() } @Test fun shutdownWithoutEnqueue() { val server = MockWebServer() server.start() server.shutdown() } @Test fun portImplicitlyStarts() {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 21.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/FastFallbackTest.kt
.build() url = serverIpv4.url("/") .newBuilder() .host("localhost") .build() } @AfterEach internal fun tearDown() { serverIpv4.shutdown() serverIpv6.shutdown() } @Test fun callIpv6FirstEvenWhenIpv4IpIsListedFirst() { dnsResults = listOf( localhostIpv4, localhostIpv6, ) serverIpv4.enqueue(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 10.6K 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)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 11.9K 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())
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Fri Apr 05 03:30:42 GMT 2024 - 12.7K bytes - Viewed (0) -
mockwebserver/api/mockwebserver3.api
public abstract class mockwebserver3/Dispatcher { public fun <init> ()V public abstract fun dispatch (Lmockwebserver3/RecordedRequest;)Lmockwebserver3/MockResponse; public fun peek ()Lmockwebserver3/MockResponse; public fun shutdown ()V } public final class mockwebserver3/MockResponse { public static final field Companion Lmockwebserver3/MockResponse$Companion; public fun <init> ()V public fun <init> (I)V public fun <init> (ILokhttp3/Headers;)V
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 03 21:59:45 GMT 2023 - 12.7K bytes - Viewed (0) -
mockwebserver-deprecated/api/mockwebserver.api
public static final field RESET_STREAM_AT_START Lokhttp3/mockwebserver/SocketPolicy; public static final field SHUTDOWN_INPUT_AT_END Lokhttp3/mockwebserver/SocketPolicy; public static final field SHUTDOWN_OUTPUT_AT_END Lokhttp3/mockwebserver/SocketPolicy; public static final field SHUTDOWN_SERVER_AFTER_RESPONSE Lokhttp3/mockwebserver/SocketPolicy; public static final field STALL_SOCKET_AT_START Lokhttp3/mockwebserver/SocketPolicy;
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jul 22 12:28:51 GMT 2023 - 10.2K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
@Synchronized @Throws(IOException::class) fun shutdown() { if (shutdown) return shutdown = true if (!started) return // Nothing to shut down. val serverSocket = this.serverSocket ?: return // If this is null, start() must have failed. // Cause acceptConnections() to break out. serverSocket.close() // Await shutdown. for (queue in taskRunner.activeQueues()) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 37.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) } /**
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 32.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt
this.writer = null taskQueue.execute("$name writer close", cancelable = false) { writerToClose.closeQuietly() } } this.taskQueue.shutdown() } streamsToClose = when { writer == null -> streams else -> null } }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 01 14:21:25 GMT 2024 - 22.1K bytes - Viewed (0)