- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 218 for ShutDown (0.12 sec)
-
mockwebserver/src/test/java/mockwebserver3/MockWebServerTest.kt
server2.start() server2.start() server2.shutdown() } @Test fun shutdownTwice() { val server2 = MockWebServer() server2.start() server2.shutdown() try { server2.start() fail<Unit>() } catch (expected: IllegalStateException) { // Expected. } server2.shutdown() }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 23.5K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/Dispatcher.kt
} /** * Release any resources held by this dispatcher. Any requests that are currently being dispatched * should return immediately. Responses returned after shutdown will not be transmitted: their * socket connections have already been closed. */ open fun shutdown() {}
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Tue Jan 23 14:31:42 UTC 2024 - 1.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractIdleService.java
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeoutException; /** * Base class for services that do not need a thread while "running" but may need one during startup * and shutdown. Subclasses can implement {@link #startUp} and {@link #shutDown} methods, each which * run in an executor which by default uses a separate thread for each method. * * @author Chris Nokleberg * @since 1.0 */ @GwtIncompatible @J2ktIncompatible
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Apr 17 13:59:28 UTC 2023 - 5.3K bytes - Viewed (0) -
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()) }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sun Oct 18 12:55:43 UTC 2020 - 1.3K bytes - Viewed (0) -
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() {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 21.9K 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!");
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Thu Apr 04 11:40:21 UTC 2024 - 1.6K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/QueueDispatcher.kt
} open fun enqueueResponse(response: MockResponse) { responseQueue.add(response) } open fun clear() { responseQueue.clear() } override fun shutdown() { responseQueue.add(DEAD_LETTER) } open fun setFailFast(failFast: Boolean) { val failFastResponse = if (failFast) { MockResponse(code = HttpURLConnection.HTTP_NOT_FOUND)
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Tue Jan 23 14:31:42 UTC 2024 - 3K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java
assertFalse(testExecutor.isTerminated()); mock.assertLastMethodCalled("isTerminated"); assertFalse(testExecutor.isShutdown()); mock.assertLastMethodCalled("isShutdown"); testExecutor.shutdown(); mock.assertLastMethodCalled("shutdown"); List<Runnable> list = testExecutor.shutdownNow(); mock.assertLastMethodCalled("shutdownNow"); assertEquals(ImmutableList.of(), list); } public void testExecute() {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 9.9K 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()) {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sun Mar 31 17:16:15 UTC 2024 - 37.4K 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) }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Tue Jan 23 14:31:42 UTC 2024 - 1.8K bytes - Viewed (0)