- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 59 for shutdown (0.17 sec)
-
mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/QueueDispatcher.kt
throw UnsupportedOperationException("unexpected call") } fun enqueueResponse(response: MockResponse) { delegate.enqueueResponse(response.wrap()) } override fun shutdown() { delegate.shutdown() } fun setFailFast(failFast: Boolean) { delegate.setFailFast(failFast) } fun setFailFast(failFastResponse: MockResponse?) { delegate.setFailFast(failFastResponse?.wrap()) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Oct 18 12:55:43 GMT 2020 - 1.3K bytes - Viewed (0) -
mockwebserver-junit4/src/main/kotlin/mockwebserver3/junit4/MockWebServerRule.kt
try { server.start() } catch (e: IOException) { throw RuntimeException(e) } } override fun after() { try { server.shutdown() } catch (e: IOException) { logger.log(Level.WARNING, "MockWebServer shutdown failed", e) } } @ExperimentalOkHttpApi companion object { private val logger = Logger.getLogger(MockWebServerRule::class.java.name) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 1.8K bytes - Viewed (1) -
mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/DeprecationBridge.kt
return delegate.dispatch(request.unwrap()).wrap() } override fun peek(): mockwebserver3.MockResponse { return delegate.peek().wrap() } override fun shutdown() { delegate.shutdown() } } } internal fun MockResponse.wrap(): mockwebserver3.MockResponse { val result = mockwebserver3.MockResponse.Builder() val copyFromWebSocketListener = webSocketListener
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.6K bytes - Viewed (0) -
samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/ClientAndServer.java
Java - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Dec 24 03:46:30 GMT 2018 - 2.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerRealBackendTest.kt
} } private val backend = TaskRunner.RealBackend(threadFactory) private val taskRunner = TaskRunner(backend) private val queue = taskRunner.newQueue() @AfterEach fun tearDown() { backend.shutdown() } @Test fun test() { val t1 = System.nanoTime() / 1e6 val delays = mutableListOf(TimeUnit.MILLISECONDS.toNanos(1000), -1L) queue.schedule("task", TimeUnit.MILLISECONDS.toNanos(750)) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.5K 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) -
samples/guide/src/main/java/okhttp3/recipes/WebSocketEcho.java
Request request = new Request.Builder() .url("ws://echo.websocket.org") .build(); client.newWebSocket(request, this); // Trigger shutdown of the dispatcher's executor so this process exits immediately. client.dispatcher().executorService().shutdown(); } @Override public void onOpen(WebSocket webSocket, Response response) { webSocket.send("Hello..."); webSocket.send("...World!");
Java - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 04 11:40:21 GMT 2024 - 1.6K 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)